20 章 多线程

20.1线程简介.

20.2创建线程

2.1继承Thread类

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


public Thread():创建一个新的线程对象。
public Thread(String threadName):创建一个名称为threadName的线程对象。

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

public class ThreadTest extends Thread{

}

完成线程真正功能的代码放在类的run(方法中,当一个类继承Thread类后,就可以在该类中覆盖 run()方法,将实现该线程功能的代码写入run()方法中,然后调用Thread类中的start()方法执行线程,也就是调用run()方法。
Thread 对象需要一个任务来执行,任务是指线程在启动时执行的工作,该工作的功能代码被写在 run()方法中。run()方法必须使用以下语法格式:


public void run(){

}

注意如果 start()方法调用一个已经启动的线程,系统将抛出IllegalThreadStateException异常。

2.2实现Runnable接口(单继承,所以要使用接口)

实现接口语法:

public class Thread extends  Object implements Runnable

实现Runnable接口的程序会创建一个Thread 对象,并将Runnable对象与Thread对象相关联。Thread    
类中有以下两个构造方法:


☑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()方法启动线程。

 import java.awt.Container;import javax.swing.JFrame;
import javax.swing.JLabel;public class SwingAndThread extends JFrame{int count =0;public SwingAndThread(){setBounds(300,200,250,100);	//绝对定位窗体大小与位置	Container container = getContentPane();	//主容器	container.setLayout(null);	//使窗体不使用任何布局管理器	lcon icon = new lmagelcon("/D20/src/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;	//使横坐标每次增加4	if (count >= 200){count = 10;	//当图标到达标签的最右边时,使其回到标签最左边	}}}};	t.start();	container.add(jl);	//启动线程	//将标签添加到容器中	setVisible(true);	//使窗体可见	setDefaultCloseOperation(EXIT_ON_CLOSE);	//设置窗体的关闭方式}public static void main(String[] args) {new SwingAndThread();}}

20.3线程的生命周期

线程具有生命周期,其中包含7种状态,分别为出生状态、就绪状态、运行状态、等待状态、休眠状态、阻塞状态和死亡状态。出生状态就是线程被创建时处于的状态,在用户使用该线程实例调用 start()方法之前线程都处于出生状态;当用户调用start()方法后,线程处于就绪状态(又被称为可执行状态);当线程得到系统资源后就进入运行状态。
一旦线程进入可执行状态,它会在就绪与运行状态下转换,同时也有可能进入等待、休眠、阻塞或死亡状态。当处于运行状态下的线程调用Thread类中的wait()方法时,该线程便进入等待状态,进入等待状态的线程必须调用Thread类中的notify0方法才能被唤醒,而调用notifyAl1O)方法可将所有处于等待状态下的线程唤醒;当线程调用Thread类中的sleep(方法时,则会进入休眠状态。如果一个线程在运行状态下发出输入/输出请求,该线程将进入阻塞状态,在其等待输入/输出结束时线程进入就绪状态,对于阻塞的线程来说,即使系统资源空闲,线程依然不能回到运行状态。当线程的run()方法执行完毕时,线程进入死亡状态。
说明
使线程处于不同状态下的方法会在20.4节中进行讲解,在此读者只需了解线程的多个状态即可。

20.4操作线程的方法

4.1线程的休眠
	import java.awt.*;import java.util.Random; import javax.swing.*;public class SleepMethodTest extends JFrame {private static Color[]color={ Color.BLACK, Color.BLUE,Color.CYAN,Color.GREEN,Color.ORANGE, Color.YELLOW, Color.RED,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;	Il定义初始坐标	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,100,y++);	//绘制直线并递增垂直坐标	if (y >=80) {y = 50;}}}});t.start();	//启动线程	}public static void main(String[]args){init(new SleepMethodTest(),100,100);}public static void init(JFrame frame, int width, int height){//初始化程序界面的方法frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); frame.setSize(width, height); frame.setVisible(true);}}
4.2线程的加入

使用join()方法加入线程

import java.awt.BorderLayout;
import javax.swing.*;
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)	break;	//跳出循环	}}});	//启动线程B	threadB.start();}}
 4.3线程的中断

现在提倡在r un()方法中使用无限循环的形式,然后使用一个布尔型标记控制循环的停止。
如果线程是因为使用了sleep()或 wait()方法:进入了就绪状态,可以使用Thread 类中interrupt)方法使线程离开run()方法,同时结束线程,但程序会会抛出 InterruptedException异常,用户可以在处理该异常时完成线程的中断业务处理,如终止while 循环。
下面的实例演示了某个线程使用interrupted0方法,同时程序抛出了InterruptedException异常,在异常处理时结束了while循环。在项目中,经常在这里执行关闭数据库连接和关闭Socket连接等操作。

import java.awt.BorderLayout;
import java.awt.event.*;
import javax.swing.*;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);}}
 4.4线程的礼让

Thread类中提供了一种礼让方法,使用 yield()方法表示,它只是给当前正处于运行状态的线程一
个提醒,告知它可以将资源礼让给其他线程    但这仅是一种暗示,没有任何一种机制保证当前线程会将资源礼让。
yield()方法使具有同样优先级的线程有过进入可执行状态的机会,在当前线程放弃执行权时会再度回到就绪状态。对于支持多任务的操作系统来说,不需要调用yield()方法,因为操作系统会为线程自动分配 CPU 时间片来执行。

20.5线程的优先级

 

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


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

20.6线程同步

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


6.1 线程安全


实际开发中,使用多线程程序的情况很多,在编写多线程程序时,应该考虑到线程安全问题,实质上线程安全问题来源于两个线程同时存取单一对象的数据。

public class ThreadSafeTest implements Runnable {//设置当前总票数int num = 10;public void run() {//设置无限循环while (true) {if (num > 0){	//判断当前票数是否大于0	try {Thread.sleep(100);	//使当前线程休眠100毫秒	} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName()+ "----票数"+ num--);//票数减1}}}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();}
}

从这个结果可以看出,最后打印出的剩下的票数为负值,这样就出现了问题。这是由于同时创建了4个线程,这4个线程执行run()方法,在num变量为1时,线程一、线程二、线程三、线程四都对num 变量有存储功能,当线程一执行run()方法时,还没有来得及做递减操作,就指定它调用sleep()方法进入就绪状态,统等。这种多线程的    这时线程二、线程三和线程四也都进入了run()方法,发现num 变 如果大于0则执行    量依然大于 0,但此时线程一休眠时间已到,将num变量值递减张票),第一个线程    同时线程二、线程三、线程四也都对num变量进行递减操作,从 而产生了负值。

6.2线程同步机制

1.同步块
Java 中提供了同步机制,可以有效地防止资源冲突。同步机制使用synchronized关键字, 
 语法如下: 

   
synchronized (Object){

}

通常将共享资源的操作放置在synchronized定义的区域内,这样当其他线程获取到这个锁时,就必须等待锁被释放后才可以进入该区域。Object为任意一个对象,每个对象都存在一个标志位,并具有两个值,分别为0和1。一个线程运行到同步块时首先检查该对象的标志位,如果为0状态,表明此同步块内存在其他线程,这时当期线程处于就绪状态,直到处于同步块中的线程执行完同步块中的代码后,这时该对象的标识位设置为1,当期线程才能开始执行同步块中的代码,并将Object对象的标识位设置为0,以防止其他线程执行同步块中的代码。

public class SynchronizedTest implements Runnable { int num = 10;//设置当前总票数public void run() {while (true){	//设置无限循环	synchronized (this){	//设置同步代码块	if (num > 0) {	//判断当前票数是否大于0	try {Thread.sleep(100);	//使当前线程体眠 100} catch (InterruptedException e) {e.printStackTrace();}//票数减 1System.out.println(Thread.currentThread().getName()+"--票数" + num--);}}}}public static void main(String[] args){//实例化类对象SynchronizedTest t = new SynchronizedTest();//以该类对象分别实例化4个线程 Thread tA= new Thread(t,"线程一"); 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,否则就会出错。
修改例20.7的代码,将共享资源操作放置在一个同步方法中,代码如下:

int num = 10;
public synchronized void doit() {    //定义同步方法
if(num>0){
try{
Thread.sleep(10);
}catch(interruptedException e){
e.printStackTrace():
System.out.printin(Thread.currentThread().getName()+"-票数” +num--);
public void run(){while(true){
doit():	//在run()方法中调用该同步方法

 

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

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

相关文章

用C++和python混合编写数据采集程序?

之前看过一篇文章&#xff0c;主要阐述的就是多种语言混合编写爬虫程序&#xff0c;结合各种语言自身优势写一个爬虫代码是否行得通&#xff1f;觉得挺有意思的&#xff0c;带着这样的问题&#xff0c;我尝试着利用我毕生所学写了一段C和python混合爬虫程序&#xff0c;目前运行…

LeetCode Hot100 84.柱状图中最大的矩形

题目&#xff1a; 给定 n 个非负整数&#xff0c;用来表示柱状图中各个柱子的高度。每个柱子彼此相邻&#xff0c;且宽度为 1 。 求在该柱状图中&#xff0c;能够勾勒出来的矩形的最大面积。 方法&#xff1a; 代码&#xff1a; class Solution {public int largestRectang…

成为AI产品经理——模型评估概述

目录 一、模型宣讲和评估的原因 二、模型宣讲 三、模型评估 1. 重要特征 ① 特征来源 ②特征意义 2.选择测试样本 3.模型性能和稳定性 一、模型宣讲和评估的原因 刘海丰老师提到他们在做一个金融AI产品未注重模型指标&#xff0c;过于注重业务指标&#xff0c;导致产生…

Python小知识

个人学习笔记&#xff0c;用于记录使用过程中好用的技巧、好用的库。 1 小知识 1.1 相对路径 1.2 打包Exe文件 命令&#xff1a; pyinstaller -F main.py其中-F&#xff1a;覆盖之前打包的文件 mian.py&#xff1a;需要打包的Python文件 PS&#xff1a;使用pyinstaller 5.1…

Docker,从入门到精通

1、DockerFile 介绍 dockerfile 是啥?dockerfile 用来构建 docker 镜像的文件。 具体步骤&#xff1a; 1、编写一个 dockerfile 文件 2、docker build 构造一个镜像 3、docker run 运行镜像 4、docker push 发布镜像 DockerFile 构建过程 1、每个保留关键字都必须是大…

人工智能-优化算法之凸集

凸性 凸性&#xff08;convexity&#xff09;在优化算法的设计中起到至关重要的作用&#xff0c; 这主要是由于在这种情况下对算法进行分析和测试要容易。 换言之&#xff0c;如果算法在凸性条件设定下的效果很差&#xff0c; 那通常我们很难在其他条件下看到好的结果。 此外&…

【Vue】绝了!还有不懂生命周期的?

生命周期 Vue.js 组件生命周期&#xff1a; 生命周期函数&#xff08;钩子&#xff09;就是给我们提供了一些特定的时刻&#xff0c;让我们可以在这个周期段内加入自己的代码&#xff0c;做一些需要的事情; 生命周期钩子中的this指向是VM 或 组件实例对象 在JS 中&#xff0c;…

微服务实战系列之Cache

前言 欢迎来到Cache&#xff08;缓存&#xff09;的世界&#xff01; 自从世界第一台计算机诞生之日起&#xff0c;人们对效率的渴望逐步增强。从CPU到存储&#xff0c;从芯片到内存&#xff0c;一批又一批的先驱以一种孜孜不倦的“工匠”精神&#xff0c;为计算机运行效率的提…

华为P40无法链接adb的解决记录

真的很讨厌华为的设备&#xff0c;很多东西啥设备都能跑得好好的&#xff0c;就华为会出问题&#xff0c;简直就是手机界的IE。 情况&#xff1a;突然无法链接adb到P40&#xff0c;拔插无效&#xff0c;关闭开发人员选项再打开也无效&#xff0c;撤销USB调试授权也无效&#x…

西南科技大学电路分析基础实验A1(一阶电路的设计)

目录 一、实验目的 二、实验设备 三、预习内容(如:基本原理、电路图、计算值等) 四、实验数据及结果分析(预习写必要实验步骤和表格) 1. 观测一阶电

leetcode:有效的括号

题目描述 题目链接&#xff1a;20. 有效的括号 - 力扣&#xff08;LeetCode&#xff09; 题目分析 题目给了我们三种括号&#xff1a;&#xff08;&#xff09;、{ }、[ ] 这里的匹配包括&#xff1a;顺序匹配和数量匹配 最优的思路就是用栈来解决&#xff1a; 括号依次入栈…

用于计算机屏幕安全摄像头系统:Screen Anytime Crack

Screen Anytime 是一款软件&#xff0c;旨在自动将整个用户会话或 PC/服务器/VM/Kiosk 的 /RDP/Citrix/RemoteApp 会话的屏幕活动记录到视频日志文件中&#xff0c;以用于记录、审核和监控目的。通过重播其高度压缩的视频&#xff0c;您可以轻松回顾单台计算机或一组服务器/PC …

Joint Bilateral Upsampling

Abstract 图像分析和增强任务&#xff08;例如色调映射、着色、立体深度和蒙太奇&#xff09;通常需要在像素网格上计算解决方案&#xff08;例如&#xff0c;曝光、色度、视差、标签&#xff09;。计算和内存成本通常要求在下采样图像上运行较小的解决方案。尽管通用上采样方…

只需十分钟快速入门Python,快速了解基础内容学习。零基础小白入门适用。

文章目录 简介特点搭建开发环境版本hello world注释文件类型变量常量数据类型运算符和表达式控制语句数组相关函数相关字符串相关文件处理对象和类连接mysql关于Python技术储备一、Python所有方向的学习路线二、Python基础学习视频三、精品Python学习书籍四、Python工具包项目源…

matlab绘图函数plot和fplot的区别

一、背景 有的函数用plot画就会报错&#xff0c;显示数据必须为可转换为双精度值的数值、日期时间、持续时间、分类或数组。 如下图所示&#xff1a; 但用fplot函数就没有问题&#xff0c;因此这里记录一下两者的区别&#xff0c;如果使用不当&#xff0c;画出的图可能就是下…

以太网通讯协议小结--持续更新中

一、以太网介绍 以太网是一种产生较早&#xff0c;使用相当广泛的局域网技术&#xff0c;局域网就是一个区域的网络互联&#xff0c;可以使办公室也可以是学校等等&#xff0c;大小规模不一。 目前以太网根据速度等级分类大概分为&#xff1a;标准以太网&#xff08;10Mbit/s…

Redis-Redis高可用集群之水平扩展

Redis3.0以后的版本虽然有了集群功能&#xff0c;提供了比之前版本的哨兵模式更高的性能与可用性&#xff0c;但是集群的水平扩展却比较麻烦&#xff0c;今天就来带大家看看redis高可用集群如何做水平扩展&#xff0c;原始集群(见下图)由6个节点组成&#xff0c;6个节点分布在三…

JOSEF 双可调漏电继电器 ZLR-T81 ZCT-80 面板嵌入式安装

ZLR-T系列漏电继电器&#xff08;以下简称继电器&#xff09;适用于交流电压为380.660V.至1140V系统中源率为50HZ电流为15~4000A线路中做有无中性点漏电保护. 系列型号 ZLR-T81漏电继电器 ZLR-T81ZCT-35漏电继电器 ZLR-T81ZCT-80漏电继电器 ZLR-T81ZCT-120漏电继电器 一、…

csv文件EXCEL默认打开乱码问题

这里讨论的问题是&#xff0c;当用记事本打开带有中文字符的csv正常时&#xff0c;用excel打开却是乱码。 简单概括就是&#xff1a;编码问题&#xff0c;windows的 excel打开csv文本文件时&#xff0c;默认使用的是系统内的ANSI&#xff0c;在中文环境下就是GB2312。如果写文件…

华为ospf和isis双点双向路由重分布的次优路径和环路终极解决方案

r5上直接导入直连路由 r3和r2进行双点双向路由重分布 查看R3去往R5产生了次优路径&#xff1a; 因为是R2先互相引入的isis和ospf&#xff0c;所以R3会产生次优路径&#xff0c;如果是R3先相互引入ospf和isis&#xff0c;那就是R2去R5会产生次优路径&#xff0c;而R3本身不会。…