Java第二十章多线程

线程简介

在 Java 中，并发机制非常重要。在以往的程序设计中，我们都是一个任务完成后再进行下一个任务，这样下一个任务的开始必须等待前一个任务的结束。Java 语言提供了并发机制，程序员可以在程序中执行多个线程，每一个线程完成一个功能，并与其他线程并发执行，这种机制被称为多线程。然而，有必要强调的是，并不是所有编程语言都支持多线程。
 

创建线程

在 Java 中，主要提供两种方式实现线程，分别为继承 java.lang.Thread 类与实现 java.lang.Runnable接口。

继承Thread类
Thread 类是 java.lang 包中的一个类，从这个类中实例化的对象代表线程，程序员启动一个新线程需要建立 Thread 实例。Thread 类中常用的两个构造方法如下:

public Thread():创建一个新的线程对象。
 public Thread(String threadName): 创建一个名称为 threadName 的线程对象。
继承 Thread 类创建一个新的线程的语法如下:

public class ThreadTest extends Thread{

}

Thread 对象需要一个任务来执行，任务是指线程在启动时执行的工作，该工作的功能代码被写在

run()方法中。run()方法必须使用以下语法格式:

public void run(){
}

主方法线程自动由 Java虚拟机负责，程序员负责启动自己的线程。代码如下:

public static void main(Stringl args) {
new ThreadTest().start()；

}

代码:

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

运行结果如下：

 

实现Runnable接口

到目前为止，线程都是通过扩展 Thread 类来创建的，如果程序员需要继承其他类(非 Thread 类)而且还要使当前类实现多线程，那么可以通过 Runnable 接口来实现。例如，一个扩展Frame 类的 GUI程序不可能再承 Thread 类，因为 Java 语言中不支持多继承，这时该类需要实现 Runnable 接口使其具有使用线程的功能。实现 Runnable 接口的语法如下:

public class Thread extends Object implements Runnable

Threa类中有以下两个构造方法:

  •  public Thread(Runnable target)。
  • public Thread(Runnable target,String name)。

这两个构造方法的参数中都存在 Runnable 实例，使用以上构造方法就可以将 Runnable 实例与
Thread 实例相关联。使用 Runnable 接口启动新的线程的步骤如下:

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

通过 Runnable 接口创建线程时，程序员首先需要编写一个实现 Runnable 接口的类，然后实例化该类的对象这样就建立了 Runnable 对象;接下来使用相应的构造方法创建 Thread 实例;最后使用该实例调用 Thread 类中的start()方法启动线程。 表明了实现 Runnable 接口创建线程的流程。
代码：

package 二十;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(400,400,500,500);	//绝对定位窗体大小与位置Container container = getContentPane();		//主容器container.setLayout(null);		//使窗体不使用任何布局管理器Icon icon = new ImageIcon("/D:/Java/eclipse/二十/src/西瓜.png");	//图标对象JLabel jL = new JLabel(icon);	//显示图标的标签jL.setBounds(100, 100, 200, 500);	//设置标签的位置与大小Thread t = new Thread() {	//定义匿名线程对象public void run() {while (true) {jL.setBounds(count, 100, 500, 200);	//将标签的横坐标用变量表示try {Thread.sleep(500);	//使线程休眠500毫秒}catch(InterruptedException e) {e.printStackTrace();}count += 9;	//使横坐标每次增加9if(count >=200){count = 10;	//当坐标到达标签的最右边时，使其回到标签最左边}}}};t.start();	//启动线程container.add(jL);	//将标签添加到容器中setVisible(true);	//使窗体可见setDefaultCloseOperation(EXIT_ON_CLOSE);	//设置窗体的关闭方式}public static void main(String[] args) {new SwingAndThread();}}

 运行结果如下：

线程的生命周期

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

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

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

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

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

操作线程的方法

线程的休眠

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

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

package 二十;
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() 方法的加入一个线程时，另外一个线程会等待该线程执行完毕后再继续执行。

代码：

package 二十;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 progressBar = new JProgressBar();	//定义两个进度条组件private JProgressBar progressBar2 = 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(progressBar,BorderLayout.NORTH);	//将进度条设置在窗体最北面getContentPane().add(progressBar2,BorderLayout.SOUTH);	//将进度条设置在窗体最南面progressBar.setStringPainted(true);		//设置进度条显示数字字符progressBar2.setStringPainted(true);threadA = new Thread(new Runnable() {	//使用匿名内部类形式初始化Thread实例int count = 0;public void run() {		//重写run()方法while(true) {progressBar.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) {progressBar2.setValue(++count);	//设置进度条的当前值try {Thread.sleep(100);	//使线程B休眠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 连接等操作。
代码：

package 二十;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 progressBar = new JProgressBar();	//创建进度条getContentPane().add(progressBar,BorderLayout.NORTH);	//将进度条设置在窗体合适位置JButton button = new JButton("停止");getContentPane().add(button,BorderLayout.SOUTH);progressBar.setStringPainted(true);	//设置进度条上显示数字Thread t= new Thread(new Runnable() {	int count = 0;public void run() {		while(true) {progressBar.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 异常。

代码：

package 二十;public class PriorityTest implements Runnable{String name;public PriorityTest(String name) {this.name = name;}@Overridepublic void run() {String tmp = "";for(int i = 0;i < 50000; i++) {	//完成5万次字符串拼接tmp += i;}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 提供了线程同步的机制来防止资源访问的冲突。

线程安全

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

代码：

package 二十;public class ThreadSafeTest implements Runnable{int num = 10;	//设置当前票数@Overridepublic 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){

}

 代码：

package 二十;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(){

}

 代码：

package 二十;public class ThreadSafeTest implements Runnable{int num = 10;	//设置当前票数public synchronized void doit() {	//定义同步方法if(num >0) {	//设置当前票数是否大于0try {Thread.sleep(10);	//使当前线程休眠100毫秒}catch(InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName()+"------票数"+num--);	//票数减一}}@Overridepublic void run() {while(true) {	//设置无限循环doit();	//在run()方法中调用该同步方法}
}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.hqwc.cn/news/224770.html

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

相关文章

一起学docker系列之十二什么是dockerfile

一起学docker系列之十二什么是dockerfile

目录 1 基本概念2 语法规则3 Dockerfile构建步骤4 Dockerfile、Docker镜像和Docker容器的关系5 保留字介绍5.1 FROM5.2 MAINTAINER5.3 RUN5.4 EXPOSE5.5 WORKDIR5.6 USER5.7 ENV5.8 ADD5.9 COPY5.10 VOLUME5.11 CMD5.12 ENTRYPOINT 6 总结7 参考地址 1 基本概念 Dockerfile是一…
阅读更多...
答题小程序挑战专题1V1PK答题模式感受竞技乐趣

答题小程序挑战专题1V1PK答题模式感受竞技乐趣

作为答题小程序的重要部分&#xff0c;专题赛是一种吸引用户参与、增加用户互动性和提高用户参与度的有效方式。下面&#xff0c;我将为大家详细介绍答题小程序的专题赛怎么玩。 首先&#xff0c;每个专题可以设置单独的开放时间。例如&#xff0c;在2024年1月1日&#xff0c;…
阅读更多...
Couchdb 命令执行漏洞复现 （CVE-2017-12636）

Couchdb 命令执行漏洞复现 （CVE-2017-12636）

Couchdb 命令执行漏洞复现 &#xff08;CVE-2017-12636&#xff09; 1、下载couchdb.py 2、修改目标和反弹地址 3、Python3调用执行即可 couchdb.py文件下载地址: https://github.com/vulhub/vulhub/blob/master/couchdb/CVE-2017-12636/exp.py ‍ 在VULFocus上开启环境 …
阅读更多...
2019年11月8日 Go生态洞察：庆祝Go语言十周年

2019年11月8日 Go生态洞察：庆祝Go语言十周年

&#x1f337;&#x1f341; 博主猫头虎&#xff08;&#x1f405;&#x1f43e;&#xff09;带您 Go to New World✨&#x1f341; &#x1f984; 博客首页——&#x1f405;&#x1f43e;猫头虎的博客&#x1f390; &#x1f433; 《面试题大全专栏》 &#x1f995; 文章图文…
阅读更多...
YOLOv8独家原创改进： AKConv（可改变核卷积），即插即用的卷积，效果秒杀DSConv | 2023年11月最新发表

YOLOv8独家原创改进： AKConv（可改变核卷积），即插即用的卷积，效果秒杀DSConv | 2023年11月最新发表

💡💡💡本文全网首发独家改进：可改变核卷积（AKConv），赋予卷积核任意数量的参数和任意采样形状，为网络开销和性能之间的权衡提供更丰富的选择，解决具有固定样本形状和正方形的卷积核不能很好地适应不断变化的目标的问题点，效果秒殺DSConv 1）AKConv替代标准卷积进行…
阅读更多...
第29期 | GPTSecurity周报

第29期 | GPTSecurity周报

GPTSecurity是一个涵盖了前沿学术研究和实践经验分享的社区&#xff0c;集成了生成预训练Transformer&#xff08;GPT&#xff09;、人工智能生成内容&#xff08;AIGC&#xff09;以及大型语言模型&#xff08;LLM&#xff09;等安全领域应用的知识。在这里&#xff0c;您可以…
阅读更多...
虚幻学习笔记2—点击场景3D物体的两种处理方式

虚幻学习笔记2—点击场景3D物体的两种处理方式

一、前言 本文使用的虚幻引擎为5.3.2&#xff0c;两种方式分别为&#xff1a;点击根物体和精准点击目标物体。 二、实现 2.1、玩家控制器中勾选鼠标点击事件&#xff1a;这一步很重要&#xff0c;如图2.1.1所示&#xff1a;在自定义玩家控制器中勾 图2.1.1 选该项&#xff0c…
阅读更多...
学习知识回顾随笔

学习知识回顾随笔

文章目录 如何远程连接MySQL数据库1.创建用户来运行&#xff0c;此用户从任何主机连接到mysql数据库2.使用IP地址来访问MySQL数据库 如何远程访问Django项目Web应用什么是Web应用应用程序的两种模式Web应用程序的优缺点 HTTP协议&#xff08;超文本传输协议&#xff09;简介HTT…
阅读更多...
KepServer配置OPC UA

KepServer配置OPC UA

KepServer在进行OPC UA配置时需要一个身份验证&#xff0c;密码是安装KepServer时输入的密码&#xff0c;但是这个用户名有些人可能不清楚&#xff0c;KepServer默认的管理员用户名为&#xff1a;administrator。 登录进去之后可以进行OPC UA服务配置。 如果想添加自定义的用户…
阅读更多...
2.ORB-SLAM3中如何从二进制文件中加载多地图、关键帧、地图点等数据结构

2.ORB-SLAM3中如何从二进制文件中加载多地图、关键帧、地图点等数据结构

目录 1 为什么保存&加载(视觉)地图 1.1 加载多地图的主函数 1.2 加载各个地图 Atlas::PostLoad 1.3 加载关键帧及地图点Map::PostLoad 1.4 恢复地图点信息 MapPoint::PostLoad 1.5 恢复关键帧信息KeyFrame::PostLoad 1 为什么保存&加载(视觉)地图 因为我们要去做导…
阅读更多...
企业如何选择安全又快速的大文件传输平台

企业如何选择安全又快速的大文件传输平台

在现代信息化社会&#xff0c;数据已经成为各个行业的重要资源&#xff0c;而数据的传输和交换则是数据价值的体现。在很多场合&#xff0c;企业需要传输或接收大文件&#xff0c;例如设计图纸、视频素材、软件开发包、数据库备份等。这些文件的大小通常在几百兆字节到几十个字…
阅读更多...
CSS新手入门笔记整理：CSS字体样式

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

字体类型&#xff1a;font-family 语法 font-family&#xff1a;字体1,字体2,...,字体n; font-family可以指定多种字体。使用多个字体时&#xff0c;将按从左到右的顺序排列&#xff0c;并且以英文逗号&#xff08;,&#xff09;隔开。如果我们不定义font-family&#xff0c…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023