第二十章 多线程总结

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

         Thread 对象需要一个任务来执行,任务是指线程在启动时执行的工作,start() 方法启动线程,该工作的功能被写在run() 方法中。
 

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

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() 方法需要一个参数用于指定该线程休眠的时间,该时间以毫秒为单位。
 

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

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

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

 
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、同步块***
        Java中提供了同步机制,可以有效地防止资源冲突。同步机制使用 synchronized 关键字,使用该关键字包含的代码块称为同步块,也称临界区。
 

synchronized(Object){
}

2、同步方法

        同步方法就是在方法前面用 synchronized 关键字修饰的方法。

synchronized void f(){ } 

 

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

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

相关文章

Vue3 Teleport

假设情景 以下面截图为例&#xff0c;A组件中可以操控数字的加减&#xff0c;想把这个功能放到B组件中使用&#xff0c;AB两个组件非父子组件&#xff0c;甚至可能被嵌套了其他组件&#xff0c;一般办法可能是将A组件数据传给AB组件的父组件&#xff0c;然后在相办法给B&#…

将二维数组ndarray转置ndarray.T

【小白从小学Python、C、Java】 【计算机等考500强证书考研】 【Python-数据分析】 将二维数组ndarray转置 ndarray.T 选择题 执行以下代码transposed_arr的输出结果为&#xff1f; import numpy as np arr np.array([[1, 2, 3], [4, 5, 6]]) transposed_arr arr.T print(&q…

MySQL索引优化实战一

#插入一些示例数据drop procedure if exists insert_emp;delimiter ;;create procedure insert_emp()begindeclare i int;set i1;while(i<100000)doinsert into employees(name,age,position) values(CONCAT(tqq,i),i,dev);set ii1;end while;end;;delimiter ;call insert_e…

数据扩增(Data Augmentation)、正则化(Regularization)和早停止(Early Stopping)

数据扩增&#xff08;Data Augmentation&#xff09;、正则化&#xff08;Regularization&#xff09;和早停止&#xff08;Early Stopping&#xff09;是深度学习中常用的三种技术&#xff0c;它们有助于提高模型的泛化性能和防止过拟合 数据扩增&#xff08;Data Augmentati…

使用Wordpress 从0-1 制作一个博客网站

一. 做网站准备 购买域名 域名使用的是二级域名&#xff1a;blog.zmrw.net&#xff08;在浏览器可以提前预览网站制作后效果&#xff09; 购买服务器 服务器使用A2 Hosting 购买Wordpress 主题 主题使用的是 Porto 主题 二. 开始建站 1. 将域名添加至 Cloudflare 2. 将…

智能优化算法应用:基于混合蛙跳算法无线传感器网络(WSN)覆盖优化 - 附代码

智能优化算法应用&#xff1a;基于混合蛙跳算法无线传感器网络(WSN)覆盖优化 - 附代码 文章目录 智能优化算法应用&#xff1a;基于混合蛙跳算法无线传感器网络(WSN)覆盖优化 - 附代码1.无线传感网络节点模型2.覆盖数学模型及分析3.混合蛙跳算法4.实验参数设定5.算法结果6.参考…

Kubernetes Pod 介绍

文章目录 &#x1f50a;博主介绍&#x1f964;本文内容Pod 介绍与原理讲解Pod 生命周期管理Pod 的健康检查 &#x1f4e2;文章总结&#x1f4e5;博主目标 &#x1f50a;博主介绍 &#x1f31f;我是廖志伟&#xff0c;一名Java开发工程师、Java领域优质创作者、CSDN博客专家、51…

记录Windows下安装redis的过程

开源博客项目Blog支持使用EasyCaching组件操作redis等缓存数据库&#xff0c;在继续学习开源博客项目Blog之前&#xff0c;准备先学习redis和EasyCaching组件的基本用法&#xff0c;本文记录在Windows下安装redis的过程。   虽然redis官网文档写着支持Linux、macOS、Windows等…

uniapp中进行地图定位

目录 一、创建map 二、data中声明变量 三、获取当前位置信息&#xff0c;进行定位 四、在methods中写移动图标获取地名地址的方法 五、最终展示效果 一、创建map <!-- 地图展示 --><view class"mymap"><!-- <view class"mymap__map"…

【.NET全栈】.net的微软API接口与.NET框架源码

文章目录 0 前言1 微软官方.net接口学习2 .NET框架源码总结 0 前言 如果浏览器打不开链接&#xff0c;换一个浏览器打开。 我是 打不开微软的链接&#xff0c;使用&#xff1a; 可以打开&#xff01;&#xff01;&#xff01; 1 微软官方.net接口学习 https://docs.microsoft…

使用项目管理工具进行新媒体运营管理的策略与方法

使用Zoho Projects项目管理工具&#xff0c;新媒体运营可轻松驾驭从策划选题、撰写到排期发布的全流程。运用项目管理工具对新媒体运营进行精细化管理&#xff0c;助力团队更高效地规划、执行和追踪各项任务与活动。 以下是运用项目管理工具管理新媒体运营的妙招&#xff1a; 1…

webpack具体实现--未完

1、前端模块打包工具webpack webpack 是 Webpack 的核心模块&#xff0c;webpack-cli 是 Webpack 的 CLI 程序&#xff0c;用来在命令行中调用 Webpack。webpack-cli 所提供的 CLI 程序就会出现在 node_modules/.bin 目录当中&#xff0c;我们可以通过 npx 快速找到 CLI 并运行…