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.hqwc.cn/news/228213.html

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

相关文章

【C++初阶(九)】 priority_queue的使用与模拟实现

本专栏内容为&#xff1a;C学习专栏&#xff0c;分为初阶和进阶两部分。 通过本专栏的深入学习&#xff0c;你可以了解并掌握C。 &#x1f493;博主csdn个人主页&#xff1a;小小unicorn ⏩专栏分类&#xff1a;C &#x1f69a;代码仓库&#xff1a;小小unicorn的代码仓库&…

Unity 关于SpriteRenderer 和正交相机缩放

float oldWidth 750f;float oldHeight 1334f;float newWidth Screen.width;float newHeight Screen.height;float oldAspect oldWidth / oldHeight;float newAspect newWidth / newHeight;//水平方向缩放float horizontalCompressionRatio newAspect / oldAspect;//垂直…

Android中的多进程

在Android中也可以像pc一样开启多进程&#xff0c;这在android的编程中通常是比较少见的&#xff0c;以为在一个app基本上都是单进程工作就已经足够了&#xff0c;有一些特殊的场景&#xff0c;我们需要用多进程来做一些额外的工作&#xff0c;比如下载工作等。 在Android的An…

文件批量重命名:多个路径文件批量改名编号并移动到同一路径的操作方法

在日常生活和工作中&#xff0c;可能会遇到需要批量重命名文件的情况。比如说&#xff0c;从不同的路径下载了一堆图片&#xff0c;或者从不同的文件夹中收集了一些文件&#xff0c;现在要将这些文件按照一定的规则进行编号命名。这种情况下&#xff0c;手动修改文件名并且移动…

NX二次开发UF_MTX3_vec_multiply 函数介绍

文章作者&#xff1a;里海 来源网站&#xff1a;https://blog.csdn.net/WangPaiFeiXingYuan UF_MTX3_vec_multiply Defined in: uf_mtx.h void UF_MTX3_vec_multiply(const double vec [ 3 ] , const double mtx [ 9 ] , double vec_product [ 3 ] ) overview 概述 Returns…

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

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

java设计模式学习之【原型模式】

文章目录 引言原型模式简介定义与用途实现方式UML 使用场景优势与劣势原型模式在spring中的应用员工记录示例代码地址 引言 原型模式是一种创建型设计模式&#xff0c;它允许对象能够复制自身&#xff0c;以此来创建一个新的对象。这种模式在需要重复地创建相似对象时非常有用…

java List集合(ArrayList,LinkedList,Vector)

Hi i,m JinXiang ⭐ 前言 ⭐ 本篇文章主要介绍java List集合的三种实现类ArrayList&#xff0c;LinkedList&#xff0c;Vector以及部分理论知识 &#x1f349;欢迎点赞 &#x1f44d; 收藏 ⭐留言评论 &#x1f4dd;私信必回哟&#x1f601; &#x1f349;博主收将持续更新学习…

基于Eclipse+Mysql+Tomcat开发的挖掘机配件营销系统

基于EclipseMysqlTomcat开发的挖掘机配件营销系统 项目介绍&#x1f481;&#x1f3fb; 大家都有目共睹&#xff0c;现在的科学技术发展很迅速。而如今&#xff0c;计算机应用已经完全融入到人们的生产和生活当中&#xff0c;特别是企业&#xff0c;现在的企业几乎都是离不开计…

如何解决中小制造业企业信息化难题?

中小企的信息化&#xff0c;难&#xff01; 一、中小制造业企业信息化困难的原因主要有以下几点&#xff1a; 资金限制&#xff1a;中小制造业企业相对于大型企业来说资金有限&#xff0c;无法投入大量资金进行信息化建设。技术水平不足&#xff1a;中小制造业企业缺乏专业的…

【力扣】189. 轮转数组

【力扣】189. 轮转数组 文章目录 【力扣】189. 轮转数组1. 题目介绍2. 解法2.1 方法一&#xff1a;不太正规&#xff0c;但是简单2.2 方法二&#xff1a;使用额外的数组2.3 方法三&#xff1a;环状替换2.4 方法四&#xff1a;数组翻转 3. Danger参考 1. 题目介绍 给定一个整数…

leetcode刷题详解十

188. 买卖股票的最佳时机 IV&#xff08;最多买卖k次&#xff09; 注意事项 这道题和最多买卖两次是一模一样的思路就是把2换成k了但是还是有几个地方需要注意的 给的整数数组可能为0k其实没有很大&#xff0c;可以想一下&#xff0c;最多为n/2(n是数组的长度) int maxProfit…