二十章 多线程

线程简介


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

创建线程

继承Thread 类


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

继承 Thread 类创建一个新的线程的语法如下:

public class ThreadTest extends Thread{
}

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

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

public void run(){
}

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

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

}

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

 

  1.  
     
    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 接口启动新的线程的步骤：
 

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

 


 例：让窗体的图标动起来
  
 

 

  1.  
     
    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秒绘制一条随机颜色的线条
  
 

 

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

代码：
 

 

  1.  
     
    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 连接等操作。
 

 代码： 
  
 

 

  1.  
     
    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 异常。
 

代码： 
  
 

 

  1.   
     
    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 提供了线程同步的机制来防止资源访问的冲突。
 

线程安全
 


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

代码： 
 

 

  1.   
     
    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){
 }
 

 

代码： 
  
 

 

  2.   
     
    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(){
 
}
 

 

 

  2.   
     
    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.mzph.cn/news/181586.shtml


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











相关文章










基于Webserver的工业数据采集控制小项目








基于Webserver的工业数据采集控制小项目




主要用到的知识点&#xff0c;http协议&#xff0c;modbus协议&#xff0c;以及进程间通信&#xff0c;消息队列&#xff0c;共享内存等 框架 数据采集 #include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#…




阅读更多...

















vue+uniapp校园寻物失物招领平台 微信小程序1f6z5








vue+uniapp校园寻物失物招领平台 微信小程序1f6z5




系统中的核心用户是管理员&#xff0c;管理员登录后&#xff0c;通过管理员菜单来管理后台系统。主要功能有&#xff1a;首页、个人中心、用户管理、物品分类管理、物品信息管理、物品归还管理、留言板管理、系统管理等功能。管理员用例如图3-7所示。 对于本网上失物招领小程序…




阅读更多...

















Linux—进程状态








Linux—进程状态




目录 
一.前言 
1.1.通过系统调用获取进程标示符 
1.2.通过系统调用创建进程   
二.进程状态 
三.Z(zombie)-僵尸进程 
四.僵尸进程危害 一.前言 
学习进程的状态&#xff0c;我们首先了解一下进程的基本数据 
1.1.通过系统调用获取进程标示符 由getpid&#xff08;&#xff09…




阅读更多...

















【Python】plt库详解和示例








【Python】plt库详解和示例




plt 是 Python 中 Matplotlib 库的一个常用别名&#xff0c;它表示 pyplot&#xff0c;这是一个用于创建图形和图形的可视化表示的工具。下面是一些 plt 函数的详解和示例&#xff0c;以帮助大家理解和使用。  目录 plt.subplots&#xff08;&#xff09;plt.savefig&#xff0…




阅读更多...

















前端算法专栏-数组-75.颜色分类








前端算法专栏-数组-75.颜色分类




介绍 
Hi 大家好。我是程序员库里&#xff0c;今天新开一个前端算法专栏。 
接下来会分类给大家分享常考算法题目。 
很多朋友也是看着这套系列算法拿到很多offer&#xff01;所以也是想分享给更多朋友&#xff0c;帮助到有需要的朋友。 分类 
数组-三路快排 
题目 
75. 颜色分…




阅读更多...

















Html网页threejs显示obj,ply三维图像实例








Html网页threejs显示obj,ply三维图像实例




程序示例精选  Html网页threejs显示obj,ply三维图像实例 如需安装运行环境或远程调试&#xff0c;见文章底部个人QQ名片&#xff0c;由专业技术人员远程协助&#xff01; 前言 
这篇博客针对《Html网页threejs显示obj,ply三维图像实例》编写代码&#xff0c;代码整洁&#xff0…




阅读更多...

















uniapp上架app store详细攻略








uniapp上架app store详细攻略




​ 目录 
uniapp上架app store详细攻略 
前言 
一、登录苹果开发者网站 
二、创建好APP 前言 
uniapp开发多端应用&#xff0c;打包ios应用后&#xff0c;会生成一个ipa后缀的文件。这个文件无法直接安装在iphone上&#xff0c;需要将这个ipa文件上架app store后&#xff0c;才…




阅读更多...

















c语言-数据在内存中的存储








c语言-数据在内存中的存储




文章目录 1. 整数在内存中的存储2. 大小端字节序和字节序判断3. 浮点数在内存中的存储 1. 整数在内存中的存储 1.整数的2进制表示方法有三种&#xff0c;即 原码、反码和补码 2. 三种表示方法均有符号位和数值位两部分&#xff0c;符号位都是用0表示“正”&#xff0c;用1表示“…




阅读更多...

















客服管理者如何有效管理客服团队，有哪些高效方式？








客服管理者如何有效管理客服团队，有哪些高效方式？




在如今的市场竞争中&#xff0c;客户服务是企业成功的关键因素之一。因此&#xff0c;客服团队的有效管理至关重要。客服管理者需要了解如何有效地管理客服团队&#xff0c;以确保客户的满意度和忠诚度&#xff0c;从而提高企业的竞争力。 以下是客服管理者如何有效管理客服团队…




阅读更多...

















CSS特效020：涌动的弹簧效果








CSS特效020：涌动的弹簧效果




CSS常用示例100专栏目录 本专栏记录的是经常使用的CSS示例与技巧&#xff0c;主要包含CSS布局&#xff0c;CSS特效&#xff0c;CSS花边信息三部分内容。其中CSS布局主要是列出一些常用的CSS布局信息点&#xff0c;CSS特效主要是一些动画示例&#xff0c;CSS花边是描述了一些CSS…




阅读更多...

















206. 反转链表








206. 反转链表




206. 反转链表 
题目&#xff1a; 
给你单链表的头节点 head &#xff0c;请你反转链表&#xff0c;并返回反转后的链表。 
示例&#xff1a; 
示例 1&#xff1a; 输入&#xff1a;head  [1,2,3,4,5]
输出&#xff1a;[5,4,3,2,1]示例 2&#xff1a; 输入&#xff1a;head  [1…




阅读更多...

















【Openstack Train安装】六、Keystone安装








【Openstack Train安装】六、Keystone安装




OpenStack是一个云计算平台的项目&#xff0c;其中Keystone是一个身份认证服务组件&#xff0c;它提供了认证、授权和目录的服务。其他OpenStack服务组件都需要使用Keystone来验证用户的身份和权限&#xff0c;并且彼此之间需要相互协作。当一个OpenStack服务组件接收到用户的请…




阅读更多...

















绿色积分如何拉伸经济发展？场景适用何处？








绿色积分如何拉伸经济发展？场景适用何处？




一、引言 绿色积分发展政策是一种新兴的商业模式&#xff0c;它旨在通过积分奖励的方式鼓励消费者和企业采取环保行为&#xff0c;促进绿色消费和可持续发展。这种商业模式不仅有利于环境保护&#xff0c;也有利于提高消费者和企业的参与度和粘性&#xff0c;为商业模式的创新和…




阅读更多...

















C++: String类接口学习








C++: String类接口学习




文章目录 STL简介一. 为什么要有string类二. STL 中的 string 类介绍1. string 类描述2. 关于 basic_string 三. string 类的常用接口1. string 类的常见构造2. string 类的容量操作size 和 lengthcapacitymax_sizereserveresize 3. string 类对象的访问及遍历操作operator[] 和…




阅读更多...

















网站公安备案流程








网站公安备案流程




1.公安备案网址 https://beian.mps.gov.cn/ 选择用户登录->法人用户登录 左边的码下载APP&#xff0c;登上去之后用APP扫右边的码&#xff0c;人脸识别




阅读更多...

















Python三级 每周练习题28








Python三级 每周练习题28




如果你感觉有收获&#xff0c;欢迎给我微信扫打赏码 ———— 以激励我输出更多优质内容 
题目: 
1.运行hex(),得到 xa&#xff0c;括号里面填什么? 2.十六进制数100&#xff0c;对应10进制数是多少? 3.int(‘13’,8) 返回值是? 4.int(‘100010’,2) 返回值是? 5.int(‘2af…




阅读更多...

















强基固本，红海云数字化重塑提升国企干部管理能力








强基固本，红海云数字化重塑提升国企干部管理能力




国有企业的干部管理体系建设具有重要的战略意义&#xff0c;对于构建高素质专业化的干部队伍&#xff0c;推动企业高质量发展至关重要。特别是在党的二十大以后&#xff0c;建设中国特色现代企业制度&#xff0c;在完善公司治理中加强党的领导&#xff0c;加强党管干部党管人才…




阅读更多...

















C# 调用 c++ dll








C# 调用 c++ dll




C# 调用 c dll 
首先 c 库 dll 要定义 
代码中定义 CPP_EXPORTS 
#ifdef LASERSDK_EXPORTS
#define CPP_EXPORTS __declspec(dllexport)
#else
#define CPP_EXPORTS __declspec(dllimport)
#endif编译器定义 LASERSDK_EXPORTS  普通函数 
c 
extern "C" CPP_EXPORTS …




阅读更多...

















ucharts中，当数据为0时，不显示








ucharts中，当数据为0时，不显示




当为0时&#xff0c;会显示出来&#xff0c;值比较小的时候&#xff0c;数据会显示在一起&#xff0c;不美观  期望效果&#xff1a;  
实现步骤&#xff1a; 我是将uCharts插件下载导入到src/uni_modules下的 
1、修改src/uni_modules/qiun-data-charts/js_sdk/u-charts/confi…




阅读更多...

















【漏洞复现】OpenTSDB 2.4.0 命令注入(CVE-2020-35476)漏洞复现








【漏洞复现】OpenTSDB 2.4.0 命令注入(CVE-2020-35476)漏洞复现




漏洞描述 
官方文档这样描述：OpenTSDB is a distributed, scalable Time Series Database (TSDB) written ontop of HBase； 
翻译过来就是，基于Hbase的分布式的，可伸缩的时间序列数据库。 
主要用途，就是做监控系统；譬如收集大规模集群（包括网络设备、操作系统、应用程序…




阅读更多...


















推荐文章












最新文章


















Copyright @ 2022~2023