并发编程的故事——Java线程

Java线程

`

文章目录

  • Java线程
  • 一、线程创建
  • 二、线程运行
  • 三、线程运行
  • 四、主线程和守护线程
  • 五、线程的五种状态
  • 六、线程的六种状态
  • 七、烧水泡茶案例

一、线程创建

创建线程方法一：
Thread重写run方法
@Slf4j(topic = "c.MyTest1")
public class MyTest1 {public static void main(String[] args) {Thread t=new Thread(){@Overridepublic void run() {log.info("好人");}};t.setName("线程1");t.start();log.info("main测试");}
}创建方法2:
直接写一个Runable传给线程Thread
@Slf4j(topic = "c.Test2")
public class Test2 {public static void main(String[] args) {Runnable r = () -> {log.debug("running");};Thread t = new Thread(r, "t2");t.start();}
}

Thread和Runable的区别
Thread实现了Runable方法，也就是说Thread可以覆盖Runable的任务方法执行run。但是也可以通过传入任务来执行对应的Runable方法(如下面代码所示)。

 @Overridepublic void run() {if (target != null) {target.run();}
}
创建方法3:
FutureTask实现了Runnable和Future，Future主要是用来返回值的。其实相当于也是一个任务类但是需要实现Callable实现类对象传入到task上。并且执行之后才能够使用task的get来获取数据，如果没有执行线程那么get就会阻塞
@Slf4j(topic = "c.MyTest2")
public class MyTest2 {public static void main(String[] args) throws ExecutionException, InterruptedException {FutureTask<Integer> task=new FutureTask<Integer>(new Callable<Integer>() {@Overridepublic Integer call() throws Exception {log.debug("你好");return 4;}});Thread t=new Thread(task,"t1");t.start();log.debug("{}",task.get());}
}

总结:更推荐方法2，原因是Runable就是任务，把任务和线程分开才能更好的分配任务。

二、线程运行

命令
jps:查看java进程
tasklist:windos查看所有进程
taskkill /F /PID XXX：杀死某个进程

三、线程运行

线程的栈
每次开启一个线程都会产生一个线程的栈给线程使用，实际上就是一开始分配的虚拟机栈。
每个栈都有多个栈帧
线程只能有一个活动栈帧

线程执行的过程
先分配栈给线程，线程调用main方法，在栈分配一个栈帧给main方法，栈帧保存锁记录、局部变量表、操作数栈、返回地址（返回到原来的栈帧方法的下一条指令）

在这里插入图片描述
线程上下文切换

导致上下文切换的条件：
时间片用完
优先级
垃圾回收
自己调用sleep、wait等

线程的状态包括：
程序计数器，记录执行到什么位置
虚拟机栈，包括所有栈帧信息

常见方法
start
线程进入就绪状态，等待调度器调用。这里相当于是开启了一个新的线程
run
执行Runnable里面的方法。这里并没有开启线程，只是通过本线程执行代码
如果开启了两次start就会出现线程状态异常的问题IlegalThreadStateException
线程的两个状态
NEW
start之后就是Runnable等待调度
sleep
线程睡眠，并把状态改为Timed Waiting，被打断的时候会抛出异常InterruptedException。可以通过TimeUnit.SECONDS.sleep来规定睡眠时间的单位。睡眠可以使用在while循环自转的地方，如果长时间自转就会消耗CPU的使用时间，其他线程无法使用
interrupt
唤醒线程，如果线程处于睡眠状态那么就会抛出异常

public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread("t1") {@Overridepublic void run() {log.debug("enter sleep...");try {Thread.sleep(2000);} catch (InterruptedException e) {log.debug("wake up...");e.printStackTrace();}}};t1.start();Thread.sleep(1000);log.debug("interrupt...");t1.interrupt();}

yield
其实就是把线程状态从Running转变到Runnable暂时让出cpu，重新去竞争
setPriority
设置优先级是给调度器进行提示，先执行这个线程，但是仍然没有办法控制线程。
join
join实际上就是卡点，就是一定要等待调用join的线程完成后才能执行下面的代码

@Slf4j(topic = "c.Test10")
public class Test10 {static int r = 0;public static void main(String[] args) throws InterruptedException {test1();}private static void test1() throws InterruptedException {log.debug("开始");Thread t1 = new Thread(() -> {log.debug("开始");sleep(1);log.debug("结束");r = 10;},"t1");t1.start();t1.join();log.debug("结果为:{}", r);log.debug("结束");}
}

同步应用案例
多线程的join只需要等待最长的那个线程就可以了，因为它们是并行执行的。
test3案例，实际上就是限时等待，如果超过时间那么就不等了。如果没有超过时间，那么结束join还是以处理完线程的任务时间为主，而不是最大的等待时间
在这里插入图片描述

@Slf4j(topic = "c.TestJoin")
public class TestJoin {static int r = 0;static int r1 = 0;static int r2 = 0;public static void main(String[] args) throws InterruptedException {test2();}public static void test3() throws InterruptedException {Thread t1 = new Thread(() -> {sleep(2);r1 = 10;});long start = System.currentTimeMillis();t1.start();// 线程执行结束会导致 join 结束log.debug("join begin");t1.join(3000);long end = System.currentTimeMillis();log.debug("r1: {} r2: {} cost: {}", r1, r2, end - start);}private static void test2() throws InterruptedException {Thread t1 = new Thread(() -> {sleep(1);r1 = 10;});Thread t2 = new Thread(() -> {sleep(2);r2 = 20;});t1.start();t2.start();long start = System.currentTimeMillis();log.debug("join begin");t1.join();log.debug("t1 join end");t2.join();log.debug("t2 join end");long end = System.currentTimeMillis();log.debug("r1: {} r2: {} cost: {}", r1, r2, end - start);}private static void test1() throws InterruptedException {log.debug("开始");Thread t1 = new Thread(() -> {log.debug("开始");sleep(1);log.debug("结束");r = 10;});t1.start();t1.join();log.debug("结果为:{}", r);log.debug("结束");}
}

在这里插入图片描述
interrupt
打断阻塞
打断sleep和wait。打断后会抛出异常到那时不会给它打上打断标记。而且这里需要给主线程睡眠一会，不然t1线程还没睡眠，主线程就已经调用打断，那么这个时候的打断是打断t1，并且加上打断标记，但是打断睡眠并不会有打断标记

@Slf4j(topic = "c.Test11")
public class Test11 {public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(() -> {log.debug("sleep...");try {Thread.sleep(5000); // wait, join} catch (InterruptedException e) {e.printStackTrace();}},"t1");t1.start();Thread.sleep(1000);log.debug("interrupt");t1.interrupt();log.debug("打断标记:{}", t1.isInterrupted());}
}

打断正常
当我们打断的事正常的线程（没在sleep或wait），那么就会给这个线程加上打断标记。但是要不要打断取决于被打断线程的意愿，其它线程只能给一个通知。

@Slf4j(topic = "c.Test12")
public class Test12 {public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(() -> {while(true) {boolean interrupted = Thread.currentThread().isInterrupted();if(interrupted){break;}}}, "t1");t1.start();Thread.sleep(1000);log.debug("interrupt");t1.interrupt();}
}

LockSupport
其实就是一个锁的支持类，它的park方法可以模拟sleep把线程进行阻塞，但是需要标记是false的时候。如果打断标记是true那么就无法使用。但是这个地方可以使用Thread.interrupted来获取打断标记状态和消除标记。

public static void test5() {Thread t1 = new Thread(()->{log.debug("park...");LockSupport.park();log.debug("unpark...");log.debug("打断状态：{}", Thread.interrupted());LockSupport.park();log.debug("unpark...");},"t1");t1.start();try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}t1.interrupt();}

四、主线程和守护线程

守护线程其实就是Daemon。也就是在其它非守护线程运行完之后，无论守护线程是否还有任务需要执行都会强制停止。
垃圾回收器是守护线程
tomcat的Acceptor和poller

@Slf4j(topic = "c.Test15")
public class Test15 {public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(() -> {while (true) {if (Thread.currentThread().isInterrupted()) {break;}}log.debug("结束");}, "t1");t1.setDaemon(true);t1.start();Thread.sleep(1000);log.debug("结束");}
}

五、线程的五种状态

1、初始：new线程的时候
2、可运行：执行了start
3、运行：线程可以使用cpu的时候
4、阻塞：不能被cpu调度器使用的时候
5、终止：线程结束的时候
在这里插入图片描述

六、线程的六种状态

NEW:初始化
RUNNABLE:包括了运行、可运行和阻塞，通常表示正在运行
WAITING：没有时间限制的等待
TIMED_WAITING:有时间限制的等待
BLOCKED:阻塞
TERMINATED:终止

七、烧水泡茶案例

join思路
其实就是老王洗烧壶和烧水，小王洗茶壶、茶杯、茶叶，等待烧水完成之后泡茶。可以用join来等待t1处理。

Slf4j(topic = "c.Test16")
public class Test16 {public static void main(String[] args) {Thread t1 = new Thread(() -> {log.debug("洗茶壶");Sleeper.sleep(1);log.debug("烧水");Sleeper.sleep(5);}, "老王");Thread t2=new Thread(()->{log.debug("洗茶壶");Sleeper.sleep(1);log.debug("洗茶叶");Sleeper.sleep(2);log.debug("洗茶杯");Sleeper.sleep(1);try {t1.join();} catch (InterruptedException e) {e.printStackTrace();}log.debug("泡茶");},"小王");t1.start();t2.start();}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/114247.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

HTML 播放器效果

HTML 播放器效果

效果图 实现代码 <!DOCTYPE HTML> <html><head><title>爱看动漫社区 | 首页 </title><link href"css/bootstrap.css" relstylesheet typetext/css /><!-- jQuery --><script src"js/jquery-1.11.0.min.js"…
阅读更多...
Mysql表关联简单介绍（inner join、left join、right join、full join不支持、笛卡尔积）

Mysql表关联简单介绍（inner join、left join、right join、full join不支持、笛卡尔积）

文章目录 0. 交集、并集、差集含义说明1. 简单演示上图七种情况0. A、B表数据准备1. left outer join 简称 left join 左表所有数据&#xff0c;右表关联数据&#xff0c;没有的以null填充2. right outer join 简称 right join&#xff0c;右表所有数据&#xff0c;左表关联数据…
阅读更多...
【java中的Set集合】HashSet、LinkedHashSet、TreeSet（最通俗易懂版！！）

【java中的Set集合】HashSet、LinkedHashSet、TreeSet（最通俗易懂版！！）

目录 一、HashSet集合 1.HashSet集合的特点 2.HashSet常用方法 二、LinkedHashSet集合 LinkedHashSet集合的特点 三、TreeSet集合 1.TreeSet集合的特点 2.TreeSet的基本使用 四、HashSet、LinkedHashSet、TreeSet的使用场景 五、list和set集合的区别 一、HashSet集合 …
阅读更多...
【Apollo学习笔记】——规划模块TASK之SPEED_BOUNDS_PRIORI_DECIDER

【Apollo学习笔记】——规划模块TASK之SPEED_BOUNDS_PRIORI_DECIDER

文章目录 前言SPEED_BOUNDS_PRIORI_DECIDER功能简介SPEED_BOUNDS_PRIORI_DECIDER相关配置SPEED_BOUNDS_PRIORI_DECIDER流程将障碍物映射到ST图中ComputeSTBoundary(PathDecision* path_decision)ComputeSTBoundary(Obstacle* obstacle)GetOverlapBoundaryPointsComputeSTBounda…
阅读更多...
Apache SeaTunnel 2.3.3 版本发布，CDC 支持 Schema Evolution！

Apache SeaTunnel 2.3.3 版本发布，CDC 支持 Schema Evolution！

时隔两个月&#xff0c; Apache SeaTunnel 终于迎来大版本更新。此次发布的 2.3.3 版本在功能和性能上均有较大优化改进&#xff0c;其中大家期待已久的 CDC Schema evolution&#xff08;DDL 变更同步&#xff09;、主键 Split 拆分、JDBC Sink 自动建表功能、SeaTunnel Zeta …
阅读更多...
4.6 TCP面向字节流

4.6 TCP面向字节流

TCP 是面向字节流的协议&#xff0c;UDP 是面向报文的协议 操作系统对 TCP 和 UDP 协议的发送方的机制不同&#xff0c;也就是问题原因在发送方。 UDP面向报文协议&#xff1a; 操作系统不会对UDP协议传输的消息进行拆分&#xff0c;在组装好UDP头部后就交给网络层处理&…
阅读更多...
C++之访问vector＜vector＜char＞＞中的vector＜char＞元素(一百八十七)

C++之访问vector＜vector＜char＞＞中的vector＜char＞元素(一百八十七)

简介&#xff1a; CSDN博客专家&#xff0c;专注Android/Linux系统&#xff0c;分享多mic语音方案、音视频、编解码等技术&#xff0c;与大家一起成长&#xff01; 优质专栏&#xff1a;Audio工程师进阶系列【原创干货持续更新中……】&#x1f680; 人生格言&#xff1a; 人生…
阅读更多...
大模型综述论文笔记6-15

大模型综述论文笔记6-15

这里写自定义目录标题 KeywordsBackgroud for LLMsTechnical Evolution of GPT-series ModelsResearch of OpenAI on LLMs can be roughly divided into the following stagesEarly ExplorationsCapacity LeapCapacity EnhancementThe Milestones of Language Models Resources…
阅读更多...
【爬虫】实验项目一：文本反爬网站的分析和爬取

【爬虫】实验项目一：文本反爬网站的分析和爬取

目录 一、实验目的 二、实验预习提示 ​编辑 三、实验内容 四、实验要求 五、实验过程 1. 基本要求&#xff1a; 2. 改进要求A 3. 改进要求B: 六、资料 1.实验框架代码&#xff1a; 2.OpenSSL&#xff1a;Win32/Win64 OpenSSL Installer for Windows - Shining Light…
阅读更多...
家政保洁行业小程序如何快速搭建

家政保洁行业小程序如何快速搭建

随着互联网的快速发展&#xff0c;家政保洁行业也逐渐向数字化转型。小程序作为一种轻量级应用&#xff0c;越来越成为各行各业进行线上推广的重要工具。那么&#xff0c;如何快速搭建家政保洁行业的小程序呢&#xff1f;本文将为你提供详细的步骤和指导。 一、准备开发环境 在…
阅读更多...
CTFhub-文件上传-MIME绕过

CTFhub-文件上传-MIME绕过

Content-Type类型有&#xff1a;HTTP content-type | 菜鸟教程 用哥斯拉生成 php 木马文件 1.php 抓包---> 修改 conten-type 类型 为 imge/jpeg 用蚁剑连接 ctfhub{8e6af8109ca15932bad4747a}
阅读更多...
是否在业务中使用大语言模型？

是否在业务中使用大语言模型？

ChatGPT取得了巨大的成功&#xff0c;在短短一个月内就获得了1亿用户&#xff0c;并激发了企业和专业人士对如何在他们的组织中利用这一工具的兴趣和好奇心。 但LLM究竟是什么&#xff0c;它们如何使你的企业受益?它只是一种炒作&#xff0c;还是会长期存在? 在这篇文章中我…
阅读更多...
ceph peering机制-状态机

ceph peering机制-状态机

本章介绍ceph中比较复杂的模块&#xff1a; Peering机制。该过程保障PG内各个副本之间数据的一致性&#xff0c;并实现PG的各种状态的维护和转换。本章首先介绍boost库的statechart状态机基本知识&#xff0c;Ceph使用它来管理PG的状态转换。其次介绍PG的创建过程以及相应的状…
阅读更多...
ceph架构及 IO流程

ceph架构及 IO流程

CEPH是由多个节点构成的集群&#xff0c;它具有良好的可扩展性和可靠性。节点之间相互通信以达到&#xff1a; 存储和检索数据 数据复制 监控集群的健康状况 保证数据的完整性 检测故障并恢复 基本架构如下图&#xff1a; 分布式对象存储系统RADOS是CEPH最为关键的技术&a…
阅读更多...
Java之API详解之BigDecimal类的详细解析

Java之API详解之BigDecimal类的详细解析

7 BigDecimal类 7.1 引入 首先我们来分析一下如下程序的执行结果&#xff1a; public class BigDecimalDemo01 {public static void main(String[] args) {System.out.println(0.09 0.01);}} 这段代码比较简单&#xff0c;就是计算0.09和0.01之和&#xff0c;并且将其结果…
阅读更多...
SoC 总线结构学习记录之系统存储总线（System Memory Bus）与私有设备总线

SoC 总线结构学习记录之系统存储总线（System Memory Bus）与私有设备总线

蜂鸟 E203 SOC总线结构&#xff1a;  蜂鸟 E203 内核 BIU 的系统存储接口 ICB 连接系统存储总线&#xff0c;通过其访问 SoC 中的若干存储组件&#xff0c;譬如 ROM&#xff0c;Flash 的只读区间等。  蜂鸟 E203 内核 BIU 的私有设备接口 ICB 连接私有设备总线&#xff0c…
阅读更多...
JVM的故事——虚拟机字节码执行引擎

JVM的故事——虚拟机字节码执行引擎

虚拟机字节码执行引擎 文章目录 虚拟机字节码执行引擎一、概述二、运行时栈帧结构三、方法调用 一、概述 执行引擎Java虚拟机的核心组成之一&#xff0c;它是由软件自行实现的&#xff0c;能够执行那些不被硬件直接支持的指令集格式。 对于不同的虚拟机实现&#xff0c;执行引…
阅读更多...
【深入解读Redis系列】Redis系列（五）：切片集群详解

【深入解读Redis系列】Redis系列（五）：切片集群详解

首发博客地址 https://blog.zysicyj.top/ 系列文章地址[1] 如果 Redis 内存很大怎么办&#xff1f; 假设一台 32G 内存的服务器部署了一个 Redis&#xff0c;内存占用了 25G&#xff0c;会发生什么&#xff1f; 此时最明显的表现是 Redis 的响应变慢&#xff0c;甚至非常慢。 这…
阅读更多...
iPhone 15 Pro与iPhone 13 Pro：最大的预期升级

iPhone 15 Pro与iPhone 13 Pro：最大的预期升级

如果你在2021年首次发布iPhone 13 Pro时就抢到了它，那么你的合同很可能即将到期。虽然距离iPhone 15系列还有几周的时间，但你可能已经在想：是时候把你的旧iPhone升级为iPhone 15 Pro了吗？ 我们认为iPhone 13 Pro是你现在能买到的最好的手机之一。但如果你想在2023年晚些时…
阅读更多...
使用openpyxl来创建一个月的日程表

使用openpyxl来创建一个月的日程表

首先你心里要有一张表的样子&#xff0c;openpyxl才能帮你创建出其余的29张。 import openpyxl from openpyxl.styles import Alignment, Font import calendar from datetime import datework_path rXX\YY\ZZ\日报-九月.xlsxtry:workbook openpyxl.load_workbook(work_path…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023