Java 的第二十章：多线程

创建线程

继承Thread 类

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

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

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

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

  1. 建立 Runnable 对象
  2. 使用参数为 Runnable 对象的构造方法创建 Thread 实例
  3. 调用 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() 方法需要一个参数用于指定该线程休眠的时间，该时间以毫秒为单位。

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

例：让进度条A等待进度条B

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

线程的安全

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

例：实现 Runnable 接口，在未考虑到线程安全问题的基础上，模拟火车站售票系统的功能


public class ThreadSafeTest implements Runnable{int num=10;//设置当前总票数public  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){

}

例：开发线程安全的火车售票系统  


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

        当某个对象调用了同步方法时，该对象上的其他同步方法必须等待该同步方法执行完毕后才能被执行。必须将每个能访问共享资源的方法修饰为 synchronized，否则就会报错。

例：修改开发线程安全的火车售票系统的代码，将共享资源操作放置在一个同步方法中


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

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

相关文章

SpringBoot学习笔记-实现微服务：匹配系统（中）

SpringBoot学习笔记-实现微服务：匹配系统（中）

笔记内容转载自 AcWing 的 SpringBoot 框架课讲义&#xff0c;课程链接&#xff1a;AcWing SpringBoot 框架课。 CONTENTS 1. 同步玩家位置1.1 游戏信息的记录1.2 实现多线程同步移动 2. 同步碰撞检测3. 实现游戏结束界面4. 持久化游戏状态4.1 创建数据库表4.2 保存游戏对局信息…
阅读更多...
入门Python+Vue 全栈开发高级BI数据的可视化实战项目几个技术点总结

入门Python+Vue 全栈开发高级BI数据的可视化实战项目几个技术点总结

PythonVue全栈开发是一种强大的技术组合&#xff0c;可以用于构建高级BI数据可视化项目。在这篇文章中&#xff0c;我将总结几个关键技术点&#xff0c;以帮助读者入门并实战这个领域。 数据处理和分析&#xff1a;Python是一种流行的数据处理语言&#xff0c;它提供了丰富的库…
阅读更多...
11-30 JavaWeb

11-30 JavaWeb

修改与删除操作 防止空指针异常 localhost:8080 -> 分页查询 修改流程&#xff1a;(先查后改(两个servlet)) 修改&#xff1a; 传用户id(用户id怎么得到 -> 循环一次得到一个user 对象 user对象里用user.getId()得到用户id) UpdateUserQueryServlet.java &#xff08;…
阅读更多...
从浏览器控制台发送get，post请求

从浏览器控制台发送get，post请求

---------------------get请求--------------------------- fetch(url, { method: get, }) .then(response > response.json()) .then(data > { // 获取到响应的数据后的处理逻辑 console.log(data); }) .catch(error > { // 请求发生错误的处理逻…
阅读更多...
Oracle存储过程返回DataSet(多个DataTable)给C#

Oracle存储过程返回DataSet(多个DataTable)给C#

一、存储过程 CREATE OR REPLACE PROCEDURE GET_SENDEXCEL_XY ( ZGJ182X OUT SYS_REFCURSOR , ZGJ182Y OUT SYS_REFCURSOR , ZXN182X OUT SYS_REFCURSOR , ZXN182Y OUT SYS_REFCURSOR , ZLH182X OUT SYS_REFCURSOR …
阅读更多...
Vue模块与小程序生命周期

Vue模块与小程序生命周期

文章目录 一、Vue中五个模块1、state2、getters3、mutations4、actions5、modules 二、小程序中的生命周期 一、Vue中五个模块 1、state 是用来存储数据的地方&#xff0c;我们需要传递的数据或者需要保存的数据都会在state中声明。 2、getters 类似于Vue中的计算属性&…
阅读更多...
html/css中位置position的绝对位置absolute顺时针盒子案例图片排序

html/css中位置position的绝对位置absolute顺时针盒子案例图片排序

目标图片&#xff1a; Dreamweaver界面&#xff1a; 代码部分&#xff1a; <!doctype html> <html> <head> <meta charset"utf-8"> <title>无标题文档</title> <style type"text/css">.red{background-color:r…
阅读更多...
element中el-form-item设置label-width=‘auto‘报错

element中el-form-item设置label-width=‘auto‘报错

文章目录 一、问题二、解决三、最后 一、问题 el-form中的设置了全局标题宽度是200px&#xff0c;此时想要对el-form-item取消标题宽度&#xff0c;设置了label-widthauto&#xff0c;结果&#xff0c;报错了~~~ <el-form label-width"200px" label-position&quo…
阅读更多...
python的itertools库

python的itertools库

itertools常用的方法如下&#xff1a; import itertools 1. 生成的列表累加&#xff0c;在生成新的列表x itertools.accumulate(range(10))print(list(x))结果&#xff1a;[0, 1, 3, 6, 10, 15, 21, 28, 36, 45] 2. 连接多个列表或者迭代器x itertools.chain(range(3), rang…
阅读更多...
强大的Kubernetes工具的完整指南

强大的Kubernetes工具的完整指南

在容器化应用程序编排方面&#xff0c;Kubernetes是市场的领导者。它允许用户在多主机环境中管理容器&#xff0c;提供工作负载分配和网络处理。 此外&#xff0c;它还提供了许多在DevOps过程中至关重要的特性&#xff0c;例如自动扩展、自动修复和负载平衡。这些功能解释了Kub…
阅读更多...
Android问题笔记四十八：蓝牙obtainMessage数据传输部分数据丢失乱序问题

Android问题笔记四十八：蓝牙obtainMessage数据传输部分数据丢失乱序问题

Unity3D特效百例案例项目实战源码Android-Unity实战问题汇总游戏脚本-辅助自动化Android控件全解手册再战Android系列Scratch编程案例软考全系列Unity3D学习专栏蓝桥系列ChatGPT和AIGC &#x1f449;关于作者 专注于Android/Unity和各种游戏开发技巧&#xff0c;以及各种资源分…
阅读更多...
YOLOv8改进 | 2023 | 通过RFAConv重塑空间注意力（深度学习的前沿突破）

YOLOv8改进 | 2023 | 通过RFAConv重塑空间注意力（深度学习的前沿突破）

一、本文介绍 本文给大家带来的改进机制是RFAConv&#xff0c;全称为Receptive-Field Attention Convolution&#xff0c;是一种全新的空间注意力机制。与传统的空间注意力方法相比&#xff0c;RFAConv能够更有效地处理图像中的细节和复杂模式(适用于所有的检测对象都有一定的…
阅读更多...
springboot+jsp+java房屋销售出租赁网站的ssm设计与实现7xcvq

springboot+jsp+java房屋销售出租赁网站的ssm设计与实现7xcvq

三、研究方案&#xff08;主要研究内容、目标、研究方法等&#xff09; 主要研究内容 房屋租售网站采用的开发框架为springboot框架&#xff0c;也就是Spring mvc、Spring、MyBatis这三个框架&#xff0c;页面设计用的是jsp技术作为动态页面文件设计&#xff0c;jsp文件里可以对…
阅读更多...
【多传感器融合】BEVFusion: 激光雷达和视觉融合框架 NeurIPS 2022

【多传感器融合】BEVFusion: 激光雷达和视觉融合框架 NeurIPS 2022

前言 BEVFusion其实有两篇&#xff0c; 【1】BEVFusion: A Simple and Robust LiDAR-Camera Fusion Framework. NeurIPS 2022 | 北大&阿里提出 【2】BEVFusion: Multi-Task Multi-Sensor Fusion with Unified Bird’s-Eye View Representation 2022 | MIT提出 本文先分…
阅读更多...
Google Chrome访问出现 NET::ERR_CERT_INVALID

Google Chrome访问出现 NET::ERR_CERT_INVALID

Google Chrome访问出现 NET::ERR_CERT_INVALID然后访问不了当前网站&#xff0c;这个是由于证书失效了&#xff0c;临时解决方式是&#xff1a; 第一种方案&#xff1a; 在Chrome提示“您的连接不是私密连接”页面的空白区域点击一下&#xff0c;然后输入“thisisunsafe”(页…
阅读更多...
Android 13.0 SystemUI增加低电量弹窗功能

Android 13.0 SystemUI增加低电量弹窗功能

1.概述 在13.0系统定制开发rom的产品时，对于低电量提醒也是个很好的体验，由于产品要求在低电量的时候增加个弹窗提醒用户电量低及时充电，所以就开发了这个功能 2.SystemUI中实现低电量弹窗功能核心类 /frameworks/base/packages/SystemUI/src/com/android/systemui/System…
阅读更多...
过滤器

过滤器

Filter:用于拦截请求Servlet:处理请求 响应结果 listener:监听器 客户端请求资源&#xff1a;正常直接请求url,同一的资源定位符来进行请求&#xff0c;服务器处理后把结果响应给你&#xff0c;但是由于filter的存在 有放行和拦截两种状态 他的作用就是拦截或者放行请求 加依…
阅读更多...
人工智能 - 目标检测：发展历史、技术全解与实战

人工智能 - 目标检测：发展历史、技术全解与实战

目录 一、早期方法&#xff1a;滑动窗口和特征提取滑动窗口机制工作原理 特征提取方法HOG&#xff08;Histogram of Oriented Gradients&#xff09;SIFT&#xff08;Scale-Invariant Feature Transform&#xff09; 二、深度学习的兴起&#xff1a;CNN在目标检测中的应用CNN的…
阅读更多...
《QDebug 2023年11月》

《QDebug 2023年11月》

一、Qt Widgets 问题交流 1. 二、Qt Quick 问题交流 1.QML 程序渲染异常&#xff08;闪烁、撕裂等&#xff09; Qt5 QML 应用 OpenGL 实现的顺序是 desktop&#xff0c;angle&#xff0c;software&#xff0c;但是经常会遇到渲染异常&#xff0c;比如鼠标在上面晃动的时候闪…
阅读更多...
[c++]—string类___深度学习string标准库成员函数与非成员函数

[c++]—string类___深度学习string标准库成员函数与非成员函数

要相信别人能做出来自己一定可以做出来&#xff0c;只不过是时间没到而已 目录 &#x1f6a9;string类对象capacity操作 &#x1f4bb;reserve()保留 &#x1f4bb;resize() &#x1f6a9;string类对象元素访问操作 &#x1f4bb;operator[]和at() &#x1f4bb;operator…
阅读更多...
最新文章

Copyright @ 2022~2023