第20章多线程

 创建线程

继承Thread 类

        Thread 类时 java.lang 包中的一个类，从类中实例化的对象代表线程，程序员启动一个新线程需要建立 Thread 实例。

         Thread 对象需要一个任务来执行，任务是指线程在启动时执行的工作，start() 方法启动线程，该工作的功能被写在run() 方法中。

例：让线程循环打印1~10的数字 

public class ThreadTest extends Thread{public void run() {for(int i=0;i<=10;i++) {System.out.print(i+" ");}}public static void main(String[] args) {ThreadTest t=new ThreadTest();t.start();}
}

实现 Runnable 接口

        线程都是通过扩展 Thread 类来创建的，如果程序员需要继承其他类（非Thread 类），而且还要是当前类实现多线程，那么可以通过  Runnable 接口来实现。

        实现 Runnable 接口的程序会创建一个 Thread 对象，并将 Runnable 对象与 Thread 对象相关联。

使用 Runnable 接口启动新的线程的步骤：

  1. 建立 Runnable 对象
  2. 使用参数为 Runnable 对象的构造方法创建 Thread 实例
  3. 调用 start() 方法启动线程

例：让窗体的图标动起来

import java.awt.Container;import javax.swing.Icon;
import javax.swing.ImageIcon;
import javax.swing.JFrame;
import javax.swing.JLabel;public class SwingAndThread extends JFrame{int count=0;//图标坐标public  SwingAndThread(){setBounds(300,200,250,100);//绝对定位窗体大小与位置Container cotainer=getContentPane();//主容器cotainer.setLayout(null);//使窗体不使用任何布局管理器Icon icon=new ImageIcon("1.gif");//图标对象JLabel jl=new JLabel(icon);//显示图标的标签jl.setBounds(10,10,200,50);//设置标签的位置与大小Thread t=new Thread() {//定义匿名线程对象public void run() {			while(true) {jl.setBounds(count,10,200,50);//将标签的横坐标用变量表示try {Thread.sleep(500);//使线程休眠500毫秒}catch(InterruptedException e) {e.printStackTrace();}count+=4;//使横坐标每次增加4if(count>=120) {count=10;//当图标到达标签的最右时，时其回到标签做左边}}}};t.start();//启动线程cotainer.add(jl);//将标签添加到容器中setVisible(true);//使窗体可见setDefaultCloseOperation(EXIT_ON_CLOSE);//设置窗体的关闭方式}public static void main(String[] args) {new SwingAndThread();}
}

 

线程的生命周期

    一旦线程进入可执行状态，它会在就绪与运行状态下转换，同时也有可能进入等待，休眠，赌塞或死亡状态。

要使线程处于就绪，有以下几种方法：

  • 调用 sleep() 方法。
  • 调用 wait() 方法。
  • 等待输入/输出完成。

当线程处于就绪状态后，可以用以下几种方法使线程再次进入运行状态：

  • 线程调用 notify() 方法。
  • 线程调用 notifyAll() 方法。
  • 线程调用 interrupt() 方法。
  • 线程的休眠时间结束。
  • 输入/输出结束。

操作线程的方法

 线程的休眠

        一种能控制线程行为的方法是调用 sleep() 方法需要一个参数用于指定该线程休眠的时间，该时间以毫秒为单位。

例：每0.1秒绘制一条随机颜色的线条

 

import java.awt.Color;
import java.awt.Graphics;
import java.util.Random;import javax.swing.JFrame;public class SleepMethodTest extends JFrame{private static Color[] color= {Color.BLACK,Color.BLUE,Color.CYAN,Color.GREEN,Color.RED,Color.ORANGE,Color.YELLOW,Color.PINK,Color.LIGHT_GRAY};//定义颜色数组private static final Random rand=new Random();//创建随机对象private static Color getC() {//获取随机颜色值的方法return color[rand.nextInt(color.length)];}public  SleepMethodTest(){Thread t=new Thread(new Runnable() {//创建匿名线程对象int x=30;//定义初始坐标int y=50;public void run() {while(true) {//无限循环try {Thread.sleep(100);//线程休眠0.1秒}catch(InterruptedException e) {e.printStackTrace();}Graphics graphics=getGraphics();//获取组件绘图上下文对象graphics.setColor(getC());//设置绘图颜色graphics.drawLine(x, y,150, y++);//绘制直线并递增垂直坐标if(y>=180) {y=50;}}}});t.start();//启动线程}public static void main(String[] args) {init(new SleepMethodTest(),200,200);}public static void init(JFrame frame,int width,int height) {//初始化程序界面的方法frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);frame.setSize(width, height);frame.setVisible(true);}
}

线程的加入

        当某个线程使用 join() 方法的加入一个线程时，另外一个线程会等待该线程执行完毕后再继续执行。

例：让进度条A等待进度条B

import java.awt.BorderLayout;import javax.swing.JFrame;
import javax.swing.JProgressBar;public class JoinTest extends JFrame{//定义两个线程private Thread threadA;private Thread threadB;//定义两个进度条组件private JProgressBar porgressBar=new JProgressBar();private JProgressBar porgressBar2=new JProgressBar();public static void main(String[] args) {JoinTest test=new JoinTest();test.setVisible(true);}public  JoinTest() {setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);setBounds(200,200,200,100);getContentPane().add(porgressBar,BorderLayout.NORTH);//将进度条设置在窗体最北面getContentPane().add(porgressBar2,BorderLayout.SOUTH);//将进度条设置在窗体最南面//设置进度条显示数字字符porgressBar.setStringPainted(true);porgressBar2.setStringPainted(true);//使用匿名内部类形式初始化 Thread 实例threadA=new Thread(new Runnable() {int count=0;public void run() {//重写 run()方法while(true) {porgressBar.setValue(++count);//设置进度条的当前值try {Thread.sleep(100);//使线程A休眠100毫秒threadB.join();//使线程B调用join()方法}catch(InterruptedException e) {e.printStackTrace();}}}});threadA.start();//启动线程AthreadB=new Thread(new Runnable() {int count=0;public void run() {while(true) {porgressBar2.setValue(++count);//设置进度条的当前值try {Thread.sleep(100);//使线程休眠100毫秒}catch(InterruptedException e) {e.printStackTrace();}if(count==100)//当count变量增长为100时break;//跳出循环}}});threadB.start();//启动线程B}}

 

线程的中断

        以往有时候会使用 stop() 方法停止线程，但当前版本的 JDK 早已废除了 stop() 方法，不建议使用 stop() 方法来停止一个线程的运行。现在提倡在 run() 方法中使用无限循环的形式，然后使用一个布尔型标记控制循环的停止。

        如果线程是因为使用了 sleep()或 wait()方法进入了就入就绪状态，可以使用 Thread()方法，同时程序破除了 InterruptedException 异常，在异常处理时结束了 while 循环。在项目中，经常在这里执行关闭数据连接和关闭 Socket 连接等操作。

例：单机按钮停止进度条滚动

 

import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JProgressBar;public class InterruptedSwing extends JFrame{public InterruptedSwing (){JProgressBar porgressBar=new JProgressBar();//创建进度条getContentPane().add(porgressBar,BorderLayout.NORTH);//将进度条设置在窗体最北面JButton button=new JButton("停止");getContentPane().add(button,BorderLayout.SOUTH);//将进度条设置在窗体最北面//设置进度条显示数字字符porgressBar.setStringPainted(true);//使用匿名内部类形式初始化 Thread 实例Thread t=new Thread(new Runnable() {int count=0;public void run() {//重写 run()方法while(true) {porgressBar.setValue(++count);//设置进度条的当前值try {Thread.sleep(100);//使线程休眠100毫秒}catch(InterruptedException e) {//捕捉InterruptedException异常System.out.println("但前线程被中断");break;}}}});button.addActionListener(new ActionListener() {@Overridepublic void actionPerformed(ActionEvent e) {t.interrupt();//中断线程}});t.start();//启动线程}public static void init(JFrame frame,int width,int height) {//初始化程序界面的方法frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);frame.setSize(width, height);frame.setVisible(true);}public static void main(String[] args) {init(new InterruptedSwing(),100,100);}
}

线程的礼让

        Thread 类提供了一种礼让方法，使用 yied()方法表示，它只是给当前正处于运行状态的线程一个提醒，告知它可以将资源礼让给其他线程，但这仅是一种暗示，没有任何一种机制保证当前线程会将资源礼让。

        yied()方法使具有同样优先级的线程有进入可执行状态的机会，在当前线程放弃执行权时再度回到就绪状态。对于支持多任务的操作系统来说，不需要调用 yied()方法，因为操作系统会为线程自动分配 CPU 时间来执行。

线程的优先级

        每个线程都具有各自的优先级，线程的优先级可以表明在程序中该线程的重要性，如果有很多线程处于就绪状态，系统会根据优先级来决定首先使哪个线程进入运行状态。但这并不意味着低优先级的线程得不到运行，而只是它运行的概率比较小，如垃圾回收线程的优先级就按照较低。

        线程的优先级可以使用 setPriority()方法调整，如果使用该方法设置的优先级不在 1~10，将产生IllegalArgumentException 异常。

例：观察不同优先级的线程执行完毕顺序

 

 
public class PriorityTest implements Runnable{String name;public PriorityTest(String name) {this.name=name;}@Overridepublic void run() {String tmp="";for(int i=0;i<5000;i++) {tmp+=i;//完成5万次字符串拼接}System.out.println(name+"线程完成任务");}public static void main(String[] args) {Thread a=new Thread(new PriorityTest("A"));a.setPriority(1);//A线程优先级最小Thread b=new Thread(new PriorityTest("B"));b.setPriority(3);Thread c=new Thread(new PriorityTest("C"));c.setPriority(7);Thread d=new Thread(new PriorityTest("D"));d.setPriority(10);//D线程优先级最大a.start();b.start();c.start();d.start();}
}

 

线程同步

        在单线程程序中，每次只能做一件事情，后面的事情需要等待前面的事情完成后才可以进行，但是如果使用多线程程序，就会发生两个线程抢占资源的问题，如两个人同事说话、两个人同时过同一个独木桥。所以，在多线程编程中需要防止这些资源访问的冲突。Java 提供了线程同步的机制来防止资源访问的冲突。

线程的安全

        在编写多线程时时，因该考虑到线程安全问题。实质上线程问题来源两个线程同时存取单一对象的数据。

例：实现 Runnable 接口，在未考虑到线程安全问题的基础上，模拟火车站售票系统的功能

 
public class ThreadSafeTest implements Runnable{int num=10;//设置当前总票数public  void run() {while(true) { //设置无限循环if(num>0) {//判断当前票数是否大于0try {Thread.sleep(100);//使当前线程休眠100毫秒}catch(InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName()+"---票数"+num--);//票数减一}}}public static void main(String[] args) {ThreadSafeTest t=new ThreadSafeTest();//实例化类对象Thread tA=new Thread(t,"线程一");//以该类对象分别实例化4个线程Thread tB=new Thread(t,"线程二");Thread tC=new Thread(t,"线程三");Thread tD=new Thread(t,"线程四");tA.start();//分别启动线程tB.start();tC.start();tD.start();}}

 

线程同步机制

        所以解决多线程资源问题的方法基本上都是采用给定时间只允许一个线程访问共享资源的方法。这时就需要给共享源上一道锁。

1、同步块

        Java中提供了同步机制，可以有效地防止资源冲突。同步机制使用 synchronized 关键字，使用该关键字包含的代码块称为同步块，也称临界区，语法如下：

synchronized(Object){

}

例：开发线程安全的火车售票系统  

 
public class ThreadSafeTest implements Runnable{int num=10;//设置当前总票数@Overridepublic void run() {while(true) {//设置无限循环synchronized(this) {//设置同步代码块if(num>0) {//判断当前拍哦书是否大于0try {Thread.sleep(100);//使当前线程休眠100毫秒}catch(InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName()+"---票数"+num--);//票数减一}}}}public static void main(String[] args) {ThreadSafeTest t=new ThreadSafeTest();//实例化类对象Thread tA=new Thread(t,"线程一");//以该类对象分别实例化4个线程Thread tB=new Thread(t,"线程二");Thread tC=new Thread(t,"线程三");Thread tD=new Thread(t,"线程四");tA.start();//分别启动线程tB.start();tC.start();tD.start();}}

 

2、同步方法

        同步方法就是在方法前面用 synchronized 关键字修饰的方法，语法如下：

synchronized void f(){ }

        当某个对象调用了同步方法时，该对象上的其他同步方法必须等待该同步方法执行完毕后才能被执行。必须将每个能访问共享资源的方法修饰为 synchronized，否则就会报错。

例：修改开发线程安全的火车售票系统的代码，将共享资源操作放置在一个同步方法中

 
public class ThreadSafeTest implements Runnable{int num=10;//设置当前总票数public  synchronized void doit() {if(num>0) {//判断当前拍哦书是否大于0try {Thread.sleep(100);//使当前线程休眠100毫秒}catch(InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName()+"---票数"+num--);//票数减一}}public void run() {while(true) { //设置无限循环doit();}}public static void main(String[] args) {ThreadSafeTest t=new ThreadSafeTest();//实例化类对象Thread tA=new Thread(t,"线程一");//以该类对象分别实例化4个线程Thread tB=new Thread(t,"线程二");Thread tC=new Thread(t,"线程三");Thread tD=new Thread(t,"线程四");tA.start();//分别启动线程tB.start();tC.start();tD.start();}}

 

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

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

相关文章

什么是yum？

什么是yum？

&#x1f388;个人主页:&#x1f388; :✨✨✨初阶牛✨✨✨ &#x1f43b;推荐专栏1: &#x1f354;&#x1f35f;&#x1f32f;C语言初阶 &#x1f43b;推荐专栏2: &#x1f354;&#x1f35f;&#x1f32f;C语言进阶 &#x1f511;个人信条: &#x1f335;知行合一 &#x1f…
阅读更多...
C#开发的OpenRA游戏之属性SelectionDecorations（12）

C#开发的OpenRA游戏之属性SelectionDecorations（12）

C#开发的OpenRA游戏之属性SelectionDecorations（12） 前面分析了显示选择框的指示器类SelectionBoxAnnotationRenderable，它的作用就是画一个四个角的方角。 这个类是在属性SelectionDecorations里调用的，如下： protected override IEnumerable<IRenderable> Rende…
阅读更多...
JOSEF 综合继电器 HJZZ-32/2 AC220V 合闸延时整定0.02-9.99S

JOSEF 综合继电器 HJZZ-32/2 AC220V 合闸延时整定0.02-9.99S

系列型号&#xff1a; HJZZ-91分闸、合闸、电源监视综合装置&#xff1b; HJZZ-92/1分闸、合闸、电源监视综合装置&#xff1b; HJZZ-92/2分闸、合闸、电源监视综合装置&#xff1b; HJZZ-92/2A分闸、合闸、电源监视综合装置&#xff1b; HJZZ-92/3分闸、合闸、电源监视综…
阅读更多...
【机器学习】决策树

【机器学习】决策树

一、原理 典型的决策树 分类树与回归树 如何用训练样本建立决策树 分裂规则 不纯度 各种不纯度指标定义 对于数值型特征和分类型特征分别详述确定分裂阈值和分裂特征的过程 对于分类树和回归树如何确定叶子节点的值 对于样本特征向量属性缺失情况如何处理 对于属性缺失情况&am…
阅读更多...
android自定义桌面应用

android自定义桌面应用

android自定义桌面应用 这篇文章主要讲下自定义桌面应用. 效果主要是调用packageManager来获取当前所有的程序,并在自定义桌面程序中展示,并支持跳转. 主要的代码如下: 1.manifest声明 <activity android:name".MainActivity"><intent-filter><ac…
阅读更多...
【uniapp】微信运行报错TypeError_ Cannot read property ‘FormData‘ of undefined

【uniapp】微信运行报错TypeError_ Cannot read property ‘FormData‘ of undefined

文章目录 一、报错详情&#xff1a;二、解决&#xff1a; 一、报错详情&#xff1a; 二、解决&#xff1a; npm install axios0.27.2 #或者 npm install axios1.3.4
阅读更多...
＜JavaEE＞ Java中线程有多少种状态（State）？状态之间的关系有什么关系？

＜JavaEE＞ Java中线程有多少种状态（State）？状态之间的关系有什么关系？

目录 一、系统内核中的线程状态 二、Java中的线程状态 一、系统内核中的线程状态 状态说明就绪状态线程已经准备就绪&#xff0c;随时可以接受CPU的调度。阻塞状态线程处于阻塞等待&#xff0c;暂时无法在CPU中执行。 二、Java中的线程状态 相比于系统内核&#xff0c;Java…
阅读更多...
内测分发平台是否支持应用的微服务化部署

内测分发平台是否支持应用的微服务化部署

内测分发平台的微服务化部署支持是现代应用开发和部署的一个重要特性。首先我们得知道什么是微服务化部署都有哪些关键功能&#xff0c;如何实施微服务化的部署。下文以我自己理解总结了几点。 图片来源:news.gulufenfa.com 微服务是一种基于独立运行的小型服务来构建应用程序…
阅读更多...
ILSVRC2012数据集处理

ILSVRC2012数据集处理

ILSVRC2012数据集处理 解压图像处理标签和图像 解压图像 先解压 tar -xvf ILSVRC2012_img_train.tar 解压之后其实还是1000个tar压缩包&#xff08;对应1000个类别&#xff09;&#xff0c;需要再次解压&#xff0c;解压脚本unzip.sh如下&#xff08;PS&#xff1a;可能需要自…
阅读更多...
智能优化算法应用：基于教与学算法无线传感器网络(WSN)覆盖优化 - 附代码

智能优化算法应用：基于教与学算法无线传感器网络(WSN)覆盖优化 - 附代码

智能优化算法应用&#xff1a;基于教与学算法无线传感器网络(WSN)覆盖优化 - 附代码 文章目录 智能优化算法应用&#xff1a;基于教与学算法无线传感器网络(WSN)覆盖优化 - 附代码1.无线传感网络节点模型2.覆盖数学模型及分析3.教与学算法4.实验参数设定5.算法结果6.参考文献7.…
阅读更多...
深度学习【二】

深度学习【二】

1.运行时错误 1.1 ModuleNotFoundError: No module named ‘torch_scatter’ 参考 https://blog.csdn.net/weixin_42421914/article/details/132875571 pip install --no-index torch-scatter -f https://pytorch-geometric.com/whl/torch-1.13.1%2Bcpu.html
阅读更多...
Day49：647. 回文子串、516.最长回文子序列

Day49：647. 回文子串、516.最长回文子序列

文章目录 647. 回文子串思路代码实现 516.最长回文子序列思路代码实现 647. 回文子串 题目链接 思路 确定dp数组&#xff08;dp table&#xff09;以及下标的含义 布尔类型的dp[i][j]&#xff1a;表示区间范围[i,j] &#xff08;注意是左闭右闭&#xff09;的子串是否是回文…
阅读更多...
亚马逊策略：通过影响者营销改造您的亚马逊商店

亚马逊策略：通过影响者营销改造您的亚马逊商店

亚马逊卖家面临着从人群中脱颖而出的持续挑战 - 如果您是那些寻求变革性方法来接触目标受众、建立信任并将您的销售推向新高度的卖家之一&#xff0c;那么影响力营销就是您的答案。 您可能遇到过令人难以置信的成功故事&#xff0c;产品一夜之间流行起来&#xff0c;仅仅是因为…
阅读更多...
集群 CPU 利用率均值达 45% ，揭秘小红书规模化混部技术实践

集群 CPU 利用率均值达 45% ，揭秘小红书规模化混部技术实践

根据 Gartner 预测数据显示&#xff1a;2024 年全球 IT 支出预计将达到 5.1 万亿美元&#xff0c;比 2023 年增长 8 %。然而&#xff0c;该机构的另一项调查数据显示&#xff1a;全球数据中心服务器平均 CPU 利用率普遍低于 20%&#xff0c;存在巨大的资源浪费。据测算&#xf…
阅读更多...
“全球金牌课程”1 月 13-14 日 · CSM 认证在线面授周末班【模块化教学】CST 导师亲授

“全球金牌课程”1 月 13-14 日 · CSM 认证在线面授周末班【模块化教学】CST 导师亲授

课堂互动练习 CSM 认证在线培训&#xff08;周末班&#xff09; 2024 年 1 月 13-14 日 Zoom 在线面授&#xff0c;全国招生 讲师: Jim Wang 王军 10 年以上 CSM/CSPO 认证课程教学交付经验&#xff0c; 5 年以上 A-CSM/CSP-SM 认证课程教学交付经验&#xff0c; 国际 Scr…
阅读更多...
CSS新手入门笔记整理：CSS字体样式

CSS新手入门笔记整理：CSS字体样式

字体类型&#xff1a;font-family 语法 font-family&#xff1a;字体1,字体2,...,字体n; font-family可以指定多种字体。使用多个字体时&#xff0c;将按从左到右的顺序排列&#xff0c;并且以英文逗号&#xff08;,&#xff09;隔开。如果我们不定义font-family&#xff0c…
阅读更多...
Apache Airflow (十四) ：Airflow分布式集群搭建及测试

Apache Airflow (十四) ：Airflow分布式集群搭建及测试

&#x1f3e1; 个人主页&#xff1a;IT贫道_大数据OLAP体系技术栈,Apache Doris,Clickhouse 技术-CSDN博客 &#x1f6a9; 私聊博主&#xff1a;加入大数据技术讨论群聊&#xff0c;获取更多大数据资料。 &#x1f514; 博主个人B栈地址&#xff1a;豹哥教你大数据的个人空间-豹…
阅读更多...
【C++】探索C++模板编程

【C++】探索C++模板编程

文章目录 什么是C模板&#xff1f;模板的基本语法类型模板参数模板函数的示例类模板的示例总结 C模板是一种强大的编程工具&#xff0c;它可以实现泛型编程&#xff0c;使代码更加灵活和可重用。本篇博客将介绍C模板的基本语法、类型模板参数和模板函数的使用&#xff0c;并通过…
阅读更多...
MaaS/PaaS/SaaS

MaaS/PaaS/SaaS

生成式AI时代的AI Infra—从DevOps->MLOps->LLMOps - 知乎距离上次讲LLM相关的内容已经过去2个月了 LLM as Controller—无限拓展LLM的能力边界&#xff0c;本文想要从AI Infra的角度出发&#xff0c;从更宏观的角度看Generative AI对AI Infra生态产生的变化&#xff0c;…
阅读更多...
Web前端开发技术：图像与多媒体文件

Web前端开发技术：图像与多媒体文件

在现代的Web开发中&#xff0c;图像和多媒体文件在各种网站和应用程序中扮演着至关重要的角色。它们不仅能提供更丰富的内容&#xff0c;还能大大提高应用程序的吸引力和用户体验。本文将深入介绍一些关键的Web前端开发技术&#xff0c;这些技术将有助于开发者在处理图像和多媒…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023