Java进阶13讲__第12讲_1/2

2024-09-09 17:52
文章标签 java 进阶 13

本文主要是介绍Java进阶13讲__第12讲_1/2,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

多线程、线程池

1.  线程概念

1.1  什么是线程

1.2  线程的好处

2.   创建线程的三种方式

注意事项

2.1  继承Thread类

2.1.1 认识 

2.1.2  编码实现 

package cn.hdc.oop10.Thread;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;public class t1 {public static final Logger LOGGER = LoggerFactory.getLogger(cn.hdc.oop10.log.t1.class);public static void main(String[] args) {AThread a = new AThread();BThread b = new BThread();a.start();b.start();for (int i = 0; i < 10; i++) {LOGGER.info("main" + i);}}
}class AThread extends Thread {public static final Logger LOGGER = LoggerFactory.getLogger(cn.hdc.oop10.log.t1.class);@Overridepublic void run() {for (int i = 0; i < 10; i++) {LOGGER.info("A" + i);}}
}class BThread extends Thread {public static final Logger LOGGER = LoggerFactory.getLogger(cn.hdc.oop10.log.t1.class);@Overridepublic void run() {for (int i = 0; i < 10; i++) {LOGGER.info("B" + i);}}
}

2.1.3  Thread类的常用方法

Thread t1 = new Thread(j, "奇数线程");
Thread t2 = new Thread(o, "偶数线程");

2.2  实现Runnable接口

2.2.1  认识 

2.2.2  编码实现 

package cn.hdc.oop10.Thread;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;//实现Runnable接口
public class t2 {public static final Logger LOGGER = LoggerFactory.getLogger(cn.hdc.oop10.log.t1.class);public static void main(String[] args) {new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {LOGGER.info("r1:" + i);}}}).start();new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {LOGGER.info("r2:" + i);}}}).start();}
}

2.3  实现Callable接口

2.3.1  与前两者区别 

2.3.2  认识 

 2.3.3  FutureTask

 2.3.4  编码实现

package cn.hdc.oop10.Thread;import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;public class t3 {public static void main(String[] args) throws ExecutionException, InterruptedException {//100以内奇数和FutureTask<Integer> j = new FutureTask<>(new Callable<>() {@Overridepublic Integer call() {int sum = 0;for (int i = 1; i <= 100; i = i + 2) {sum += i;}return sum;}});//100以内偶数和FutureTask<Integer> o = new FutureTask<>(new Callable<>() {@Overridepublic Integer call() {int sum = 0;for (int i = 0; i <= 100; i += 2) {sum += i;}return sum;}});Thread t1 = new Thread(j);Thread t2 = new Thread(o);t1.start();t2.start();Integer jNum = j.get();Integer oNum = o.get();System.out.println("奇数和是" + jNum + ",偶数和是" + oNum + ",总和是" + (jNum + oNum));}
}

 2.4  三种方式的不同

 2.5  Thread类方法补充

2.5.1  yield

Thread.yield() 方法的作用是:
暂停当前线程的执行:使当前正在运行的线程暂停,并允许其他具有相同优先级的线程获得运行的机会。
优化同优先级线程调度:当多个同优先级的线程频繁交互资源时,使用 yield() 可以让出CPU时间片给其他线程,从而达到更均衡的调度。
非阻塞方式放弃少量执行时间:不同于 sleep() 会让出让出的时间内线程进入等待状态,yield() 是一个提示给调度器,调度器可以选择是否接受此提示。

package cn.hdc.oop10.newMethods;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;//yield
public class t1 {public static final Logger LOGGER = LoggerFactory.getLogger(t1.class);public static void main(String[] args) {//需求:创建两个线程,分别用于打印10个A和10个B,最后观察下输出顺序Thread item = new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {Thread.yield();LOGGER.info("第一线程");}}}, "A");Thread e = new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {LOGGER.info("第二线程");}}}, "B");item.start();e.start();}
}

2.5.2  interrupt

item.interrupt()
功能:中断指定的线程。
作用:将指定线程的中断状态标志设置为 true。
语法:item.interrupt()。


item.interrupted()
功能:检查并清除当前线程的中断状态。
作用:返回当前线程是否被中断,并清除中断状态标志。
语法:item.interrupted()。

package cn.hdc.oop10.newMethods;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;//yield
public class t1 {public static final Logger LOGGER = LoggerFactory.getLogger(t1.class);public static void main(String[] args) throws InterruptedException {//需求:创建两个线程,分别用于打印10个A和10个B,最后观察下输出顺序Thread item = new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {if (Thread.currentThread().isInterrupted()) {LOGGER.error("线程1被中断");try {LOGGER.warn("线程1尝试恢复");Thread.currentThread().interrupted();LOGGER.warn("线程1恢复");Thread.sleep(3000);} catch (InterruptedException e) {throw new RuntimeException(e);}}LOGGER.info("第一线程");}}}, "A");Thread e = new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {LOGGER.info("第二线程");}}}, "B");e.start();
//        e.join();item.start();item.interrupt();}
}

2.5.3  守护线程

守护线程的概念
在Java中,守护线程(Daemon Thread)是一种特殊类型的后台线程,它不会阻止程序的退出。当Java虚拟机中只剩下守护线程时,JVM就会自动退出。通常守护线程用于执行一些后台任务,比如垃圾回收线程就是一个典型的守护线程。
如何设置守护线程
在Java中可以通过调用 Thread.setDaemon(true) 方法将一个线程设置为守护线程,必须在调用 start() 方法之前设置。

package cn.hdc.oop10.newMethods;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;//yield
public class t1 {public static final Logger LOGGER = LoggerFactory.getLogger(t1.class);public static void main(String[] args) throws InterruptedException {//需求:创建两个线程,分别用于打印10个A和10个B,最后观察下输出顺序Thread item = new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {if (Thread.currentThread().isInterrupted()) {LOGGER.error("线程1被中断");return;}LOGGER.info("第一线程");}}}, "A");item.setDaemon(true); // 设置为守护线程Thread e = new Thread(new Runnable() {@Overridepublic void run() {for (int i = 0; i < 10; i++) {LOGGER.info("第二线程");}}}, "B");e.start();
//        e.join();item.start();item.interrupt();}
}

2.5.4  线程优先级

        线程优先级是在多线程环境中用来影响线程调度的一个因素,它决定了线程获取CPU时间片的顺序。具有较高优先级的线程通常会被操作系统或运行时环境优先调度执行,而较低优先级的线程则可能得到较少的执行机会。
在Java中,线程优先级是一个介于1(Thread.MIN_PRIORITY)到10(Thread.MAX_PRIORITY)之间的整数值,默认优先级为5(Thread.NORM_PRIORITY)。虽然可以设置线程的优先级,但是需要注意的是线程的实际调度仍然受到底层操作系统的影响,并且并不是所有操作系统都会严格遵守Java设定的优先级。
        线程优先级的设置可以在创建线程时或者之后通过setPriority()方法进行更改。然而,即使设置了优先级,也不能保证高优先级的线程一定会优先执行,因为最终的调度结果还依赖于操作系统的调度策略和其他因素。因此,线程优先级更多地是一种提示性的机制,而不是严格的执行顺序保证。

这篇关于Java进阶13讲__第12讲_1/2的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1151868

相关文章

Java中流式并行操作parallelStream的原理和使用方法

《Java中流式并行操作parallelStream的原理和使用方法》本文详细介绍了Java中的并行流(parallelStream)的原理、正确使用方法以及在实际业务中的应用案例,并指出在使用并行流... 目录Java中流式并行操作parallelStream0. 问题的产生1. 什么是parallelS

Java中Redisson 的原理深度解析

《Java中Redisson的原理深度解析》Redisson是一个高性能的Redis客户端,它通过将Redis数据结构映射为Java对象和分布式对象,实现了在Java应用中方便地使用Redis,本文... 目录前言一、核心设计理念二、核心架构与通信层1. 基于 Netty 的异步非阻塞通信2. 编解码器三、

SpringBoot基于注解实现数据库字段回填的完整方案

《SpringBoot基于注解实现数据库字段回填的完整方案》这篇文章主要为大家详细介绍了SpringBoot如何基于注解实现数据库字段回填的相关方法,文中的示例代码讲解详细,感兴趣的小伙伴可以了解... 目录数据库表pom.XMLRelationFieldRelationFieldMapping基础的一些代

一篇文章彻底搞懂macOS如何决定java环境

《一篇文章彻底搞懂macOS如何决定java环境》MacOS作为一个功能强大的操作系统,为开发者提供了丰富的开发工具和框架,下面:本文主要介绍macOS如何决定java环境的相关资料,文中通过代码... 目录方法一:使用 which命令方法二:使用 Java_home工具(Apple 官方推荐)那问题来了,

Java HashMap的底层实现原理深度解析

《JavaHashMap的底层实现原理深度解析》HashMap基于数组+链表+红黑树结构,通过哈希算法和扩容机制优化性能,负载因子与树化阈值平衡效率,是Java开发必备的高效数据结构,本文给大家介绍... 目录一、概述:HashMap的宏观结构二、核心数据结构解析1. 数组(桶数组)2. 链表节点(Node

Java AOP面向切面编程的概念和实现方式

《JavaAOP面向切面编程的概念和实现方式》AOP是面向切面编程,通过动态代理将横切关注点(如日志、事务)与核心业务逻辑分离,提升代码复用性和可维护性,本文给大家介绍JavaAOP面向切面编程的概... 目录一、AOP 是什么?二、AOP 的核心概念与实现方式核心概念实现方式三、Spring AOP 的关

详解SpringBoot+Ehcache使用示例

《详解SpringBoot+Ehcache使用示例》本文介绍了SpringBoot中配置Ehcache、自定义get/set方式,并实际使用缓存的过程,文中通过示例代码介绍的非常详细,对大家的学习或者... 目录摘要概念内存与磁盘持久化存储:配置灵活性:编码示例引入依赖:配置ehcache.XML文件:配置

Java 虚拟线程的创建与使用深度解析

《Java虚拟线程的创建与使用深度解析》虚拟线程是Java19中以预览特性形式引入,Java21起正式发布的轻量级线程,本文给大家介绍Java虚拟线程的创建与使用,感兴趣的朋友一起看看吧... 目录一、虚拟线程简介1.1 什么是虚拟线程?1.2 为什么需要虚拟线程?二、虚拟线程与平台线程对比代码对比示例:三

Java中的.close()举例详解

《Java中的.close()举例详解》.close()方法只适用于通过window.open()打开的弹出窗口,对于浏览器的主窗口,如果没有得到用户允许是不能关闭的,:本文主要介绍Java中的.... 目录当你遇到以下三种情况时,一定要记得使用 .close():用法作用举例如何判断代码中的 input

Spring Gateway动态路由实现方案

《SpringGateway动态路由实现方案》本文主要介绍了SpringGateway动态路由实现方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随... 目录前沿何为路由RouteDefinitionRouteLocator工作流程动态路由实现尾巴前沿S