第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();	//启动线程A
	threadB= 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(){
		@Override
		public 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; 
	}
	@Override
	public 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();}
						//票数减 1
						System.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()方法中调用该同步方法


 

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

[跑代码]BK-SDM: A Lightweight, Fast, and Cheap Version of Stable Diffusion

Installation(下载代码-装环境) conda create -n bk-sdm python3.8 conda activate bk-sdm git clone https://github.com/Nota-NetsPresso/BK-SDM.git cd BK-SDM pip install -r requirements.txt Note on the torch versions weve used torch 1.13.1 for MS-COCO evaluation…

简单好用!日常写给 ChatGPT 的几个提示词技巧

ChatGPT 很强&#xff0c;但是有时候又显得很蠢&#xff0c;下面是使用 GPT4 的一个实例&#xff1a; 技巧一&#xff1a;三重冒号 """ 引用内容使用三重冒号 """&#xff0c;让 ChatGPT 清晰引用的内容&#xff1a; 技巧二&#xff1a;角色设定…

C++中的map和set的使用

C中的map详解 关联式容器键值对树形结构的关联式容器set的使用1. set的模板参数列表2. set的构造3. set的迭代器4. set的容量5. set修改操作6. set的使用举例 map1. map的简介2. map的模板参数说明3. map的构造4. map的迭代器5. map的容量与元素访问6. map的元素修改 multimap和…

centos8 下载

下载网址 Download 直接下载地址 https://mirrors.cqu.edu.cn/CentOS/8-stream/isos/x86_64/CentOS-Stream-8-20231127.0-x86_64-dvd1.iso 这个版本安装的时候方便

增强静态数据的安全性

静态数据是数字数据的三种状态之一&#xff0c;它是指任何静止并包含在永久存储设备&#xff08;如硬盘驱动器和磁带&#xff09;或信息库&#xff08;如异地备份、数据库、档案等&#xff09;中的数字信息。 静态数据是指被动存储在数据库、文件服务器、端点、可移动存储设备…

一篇文章带你掌握MongoDB

文章目录 1. 前言2. MongoDB简介3. MongoDB与关系型数据库的对比4. MongoDB的安装5. Compass的使用6. MongoDB的常用语句7. 总结 1. 前言 本文旨在帮助大家快速了解MongoDB,快速了解和掌握MongoDB的干货内容. 2. MongoDB简介 MongoDB是一种NoSQL数据库&#xff0c;采用了文档…

基于SpringBoot的在线视频教育平台的设计与实现

摘 要 随着科学技术的飞速发展&#xff0c;各行各业都在努力与现代先进技术接轨&#xff0c;通过科技手段提高自身的优势&#xff1b;对于在线视频教育平台当然也不能排除在外&#xff0c;随着网络技术的不断成熟&#xff0c;带动了在线视频教育平台&#xff0c;它彻底改变了过…

C++ -- 每日选择题 -- Day2

第一题 1. 下面代码中sizeof(A)结果为&#xff08;&#xff09; #pragma pack(2) class A {int i;union U{char str[13];int i;}u;void func() {};typedef char* cp;enum{red,green,blue}color; }; A&#xff1a;20 B&#xff1a;21 C&#xff1a;22 D&#xff1a;24 答案及解析…

Python基础学习之包与模块详解

文章目录 前言什么是 Python 的包与模块包的身份证如何创建包创建包的小练习 包的导入 - import模块的导入 - from…import导入子包及子包函数的调用导入主包及主包的函数调用导入的包与子包模块之间过长如何优化 强大的第三方包什么是第三方包如何安装第三方包 总结关于Python…

[pyqt5]PyQt5之如何设置QWidget窗口背景图片问题

目录 PyQt5设置QWidget窗口背景图片 QWidget 添加背景图片问题QSS 背景图样式区别PyQt设置窗口背景图像&#xff0c;以及图像自适应窗口大小变化 总结 PyQt5设置QWidget窗口背景图片 QWidget 添加背景图片问题 QWidget 创建的窗口有时并不能直接用 setStyleSheet 设置窗口部分…

2023.11.27 使用anoconda搭建tensorflow环境

2023.11.27 使用anoconda搭建tensorflow环境 提供一个简便安装tensorflow的方法 1. 首先安装anoconda&#xff0c;安装过程略&#xff0c;注意安装的时候勾选安装anoconda prompt 2. 进入anoconda prompt 3. 建立python版本 conda create -n tensorflow1 python3.84. 激活t…

Java开发规范(简洁明了)

本篇规范基于阿里巴巴开发手册&#xff0c;总结了一些主要的开发规范&#xff0c;希望对大家有帮助。 目录 1. 命名规范&#xff1a; 2. 缩进和空格&#xff1a; 3. 花括号&#xff1a; 4. 注释&#xff1a; 5. 空行&#xff1a; 6. 导入语句&#xff1a; 7. 异常处理&a…

源 “MySQL 8.0 Community Server“ 的 GPG 密钥已安装,但是不适用于此软件包。请检查源的公钥 URL 是否配置正确。

源 “MySQL 8.0 Community Server“ 的 GPG 密钥已安装&#xff0c;但是不适用于此软件包。请检查源的公钥 URL 是否配置正确。yum install mysql-server --nogpgcheck

电子商务网站的技术 SEO:完整指南

技术 SEO 涉及对您的网站进行更改&#xff0c;这些更改由搜索引擎蜘蛛读取并由搜索结果索引。它简化了搜索引擎读取您网站的方式。如果不包括技术 SEO 服务&#xff0c;你就不可能有一个成功的电子商务 SEO 计划。主要目标是增强网站的框架。 在线商店的技术搜索引擎优化建议 …

熟悉SVN基本操作-(SVN相关介绍使用以及冲突解决)

一、SVN相关介绍 1、SVN是什么? 代码版本管理工具它能记住你每次的修改查看所有的修改记录恢复到任何历史版本恢复已经删除的文件 2、SVN跟Git比&#xff0c;有什么优势 使用简单&#xff0c;上手快目录级权限控制&#xff0c;企业安全必备子目录checkout&#xff0c;减少…

Redis应用的16个场景

常见的16种应用场景: 缓存、数据共享分布式、分布式锁、全局 ID、计数器、限流、位统计、购物车、用户消息时间线 timeline、消息队列、抽奖、点赞、签到、打卡、商品标签、商品筛选、用户关注、推荐模型、排行榜. 1、缓存 String类型 例如&#xff1a;热点数据缓存&#x…

【驱动】SPI驱动分析(四)-关键API解析

关键API 设备树 设备树解析 我们以Firefly 的SPI demo 分析下dts中对spi的描述&#xff1a; /* Firefly SPI demo */ &spi1 {spi_demo: spi-demo00{status "okay";compatible "firefly,rk3399-spi";reg <0x00>;spi-max-frequency <48…

C#工程中Form_xx.cs不能在设计器中查看

环境&#xff1a;VS2022 直接上图&#xff1a; 原因&#xff1a; 写了个类在Form_xx.cs中从For继承的部分类之前&#xff0c;移动到之后&#xff0c;保证窗体类是代码中的首个类即可&#xff0c;如图&#xff1a;

python pytorch实现RNN,LSTM,GRU,文本情感分类

python pytorch实现RNN,LSTM&#xff0c;GRU&#xff0c;文本情感分类 数据集格式&#xff1a; 有需要的可以联系我 实现步骤就是&#xff1a; 1.先对句子进行分词并构建词表 2.生成word2id 3.构建模型 4.训练模型 5.测试模型 代码如下&#xff1a; import pandas as pd im…

【强迫症患者必备】SpringBoot项目中Mybatis使用mybatis-redis开启三级缓存必须创建redis.properties优化方案

springboot项目中mybatis使用mybatis-redis开启三级缓存需要创建redis.properties优化方案 前言下载mybatis-redis源码分析RedisCache 代码RedisConfigurationBuilder的parseConfiguration方法 优化改造1.创建JedisConfig类2.复制RedisCache代码创建自定义的MyRedisCache3.指定…