当前位置: 首页 > news >正文

Thread

Thread

  • 线程
    • 启动线程
    • 第一种创建线程
    • 线程的第二种创建方式
    • 使用匿名内部类完成线程的两种创建
  • Thread API
    • 线程的优先级
    • 线程提供的静态方法
    • 守护线程
      • 用户线程和守护线程的区别体现在进程结束时
  • 多线并发安全问题
    • 同步块

线程

启动线程

启动线程:调用线程的start方法,而不是直接调用run方法
当线程调用start方法后就会纳入到线程调度器中统一调度.第一次获取时间片后会开始自动执行它的run方法

第一种创建线程

class MyThread1 extends Thread{public void run(){for (int i = 0; i < 1000; i++) {System.out.println("你是谁啊?");}}
}
class MyThread2 extends Thread{public void run(){for (int i = 0; i < 1000; i++) {System.out.println("开门,查水表的!");}}
}

优点:

  1. 结构简单,便于使用匿名内部类形式创建

缺点:

  1. 存在继承冲突问题
    当我们定义的类需要是一个线程时,我们要继承Thread,但是同时我们还需要继承另一个类来复用方法,
    由于java是单继承的,这会导致出现了继承冲突问题

  2. 线程与线程要执行的任务存在了必然的耦合关系
    定义一个线程的同时重写了run方法来定义线程的任务,这会导致线程和任务绑定在一起,没有办法最大程度的重用线程

线程的第二种创建方式

class MyRunnable1 implements Runnable{public void run(){for (int i = 0; i < 1000; i++) {System.out.println("你是谁啊?");}}
}
class MyRunnable2 implements Runnable{public void run(){for (int i = 0; i < 1000; i++) {System.out.println("开门,查水表的!");}}
}

使用匿名内部类完成线程的两种创建

Runnable r2 = () -> {for (int i = 0; i < 1000; i++) {System.out.println("开门!查水表!");}
};
Thread t2 = new Thread(r2);
Thread t1 = new Thread(() -> {for (int i = 0; i < 1000; i++) {System.out.println("你是谁啊?");}
});

请添加图片描述

Thread API

线程的优先级

线程有10个优先级,分别用整数1-10表示
1为最低优先级,10为最高优先级,5为默认值
Thread定义了上下限的常量

  • Thread.MAX_PRIORITY为最高优先级,对应整数10
  • Thread.MIN_PRIORITY为最低优先级,对应整数1
  • Thread.NORM_PRIORITY为默认优先级,对应整数5

优先级越高的线程获取时间片的次数越多,线程调用start方法后就纳入到线程调度器中被统一管理,线程没有主动索取时间片的能力,只能被动被分配

 public static void main(String[] args) {Thread min = new Thread(){public void run(){for (int i = 0; i < 10000; i++) {System.out.println("min");}}};Thread max = new Thread(){public void run(){for (int i = 0; i < 10000; i++) {System.out.println("max");}}};Thread norm = new Thread(){public void run(){for (int i = 0; i < 10000; i++) {System.out.println("nor");}}};min.setPriority(Thread.MIN_PRIORITY);max.setPriority(Thread.MAX_PRIORITY);min.start();norm.start();max.start();}

请添加图片描述

线程提供的静态方法

  • static void sleep(long millis)
    该方法可以让执行该方法的线程主动进入阻塞状态指定毫秒,超时后线程会主动回到RUNNABLE状态再次开始并发
public static void main(String[] args) {System.out.println("程序开始了");try {Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("程序结束了");}

sleep方法要求必须处理中断异常InterruptedException
当一个线程调用sleep方法处于睡眠阻塞的过程中,此时该线程的interrupt方法被调用,那么就会立即中断其睡眠阻塞,此时sleep方法会立即抛出中断异常

public static void main(String[] args) {Thread lin = new Thread("林永健"){public void run(){System.out.println(getName()+":刚美完容,睡一会吧...");try {Thread.sleep(300000000);} catch (InterruptedException e) {System.out.println(getName()+":干嘛呢!干嘛呢!干嘛呢!都破了相了!");}System.out.println(getName()+":醒了");}};Thread huang = new Thread("黄宏"){public void run(){System.out.println(getName()+":大锤80!小锤40!开始砸墙!");for(int i=0;i<5;i++){System.out.println(getName()+":80!");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}System.out.println("咣当!!");System.out.println(getName()+":大哥!搞定!");lin.interrupt();//中断lin线程的睡眠阻塞}};lin.start();huang.start();}

请添加图片描述

守护线程

我们正常创建出来的线程称为"用户线程"或"前台线程"。守护线程是通过用户线程调用setDaemon(true)在启动前设置转变而来的.守护线程一般也可以称为后台线程

用户线程和守护线程的区别体现在进程结束时

当进程中所有用户线程都结束时,进程就会结束,结束前会无差别杀死所有还在运行的守护线程
GC就是运行在守护线程上的

public static void main(String[] args) {Thread rose = new Thread(){public void run(){for(int i=0;i<5;i++){System.out.println("rose:let me go!");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}System.out.println("rose:啊啊啊啊啊AAAAAAaaaaaaa....");System.out.println("pia!");}};Thread jack = new Thread(){public void run(){while(true){System.out.println("jack:you jump!i jump!");try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}};rose.start();jack.setDaemon(true);//设置为守护线程,必须在线程启动前进行设置否则会抛出异常jack.start();//while (true);//如果main方法不结束,jack是不会结束的}//main方法执行完毕,主线程就结束了

请添加图片描述

多线并发安全问题

当多个线程并发操作同一临界资源,由于线程切换时机不确定,导致执行顺序出现混乱从而引起不良后果

临界资源:
操作该资源的完整过程同一时刻只能被单个线程进行

/*** 使用当前类理解并发安全问题的产生* 以银行取钱业务为例,如果多个人从同一个账号上取钱所出现的并发全问题.*/
public class Bank {private int account = 20000;public boolean getMoney(int money) {int account = getAccount();if (account >= money) {//余额>=取款金额account = account - money;Thread.yield(); //主动放弃时间片目的模拟执行到这里时CPU时间片用完了saveAccount(account); //重新记账return true; //取款成功}return false; //取款失败}public void saveAccount(int account) {this.account = account;}public int getAccount() {return account;}}
public static boolean success1 = false;//表示t1线程是否取款成功
public static boolean success2 = false;//表示t2线程是否取款成功
public static int sum = 0;//记录一共测试了几轮public static void main(String[] args) {//实例化一个BankBank bank = new Bank();while(true) {sum++;Thread t1 = new Thread() {public void run() {success1 = bank.getMoney(20000);}};Thread t2 = new Thread() {public void run() {success2 = bank.getMoney(20000);}};t1.start();t2.start();try {/*当主线程执行完上述启动t1和t2的代码后,让主线程阻塞5毫秒(目的是等待t1和t2执行完毕)*/Thread.sleep(5);} catch (InterruptedException e) {e.printStackTrace();}if(success1&&success2){//都为true则说明同时取款成功System.out.println("漏洞产生,两个线程同时取款成功!总共尝试了"+sum+"次");break;}else{bank.saveAccount(20000);//将银行账号重新存入20000}}}

请添加图片描述

同步块

Java同步块是一种同步机制,它可以确保在同一时刻只有一个线程可以执行特定的代码块或方法。这种机制可以防止多个线程同时修改同一数据,从而防止出现竞态条件。

  • 同步块可以更准确的控制需要多个线程同步执行的代码片段

同步块要求指定同步监视器对象,该对象选取有两个必要的要求:

  1. 必须是一个引用类型对象
  2. 多个需要同步执行该代码片段的线程看到的必须是"同一个"同步监视器对象

合适的锁对象选取:
在具有并发安全问题时,多个线程看到的是同一个对象,不存在并发安全问题时看到的则不是同一个对象.
选取原则:
通常选取临界资源作为同步监视器对象,即:抢谁就锁谁
语法:

  • synchronized(同步监视器对象){
    需要多个线程同步执行的代码片段
    }

有效的缩小同步范围可以在保证并发安全的前提下提高并发效率

public static void main(String[] args) {Shop shopA = new Shop();Shop shopB = new Shop();Thread t1 = new Thread("Tom"){public void run(){shopA.buy();}};Thread t2 = new Thread("Jerry"){public void run(){shopB.buy();}};t1.start();t2.start();}
}
class Shop{/*在方法上直接使用synchronized,那么同步监视器对象不可选,只能是this*/
//    public synchronized void buy(){public void buy(){try {Thread t = Thread.currentThread();//获取运行buy方法的线程System.out.println(t.getName()+":正在挑衣服...");Thread.sleep(5000);synchronized (this) {System.out.println(t.getName() + ":正在试衣服...");Thread.sleep(5000);}System.out.println(t.getName()+":结账离开");} catch (InterruptedException e) {e.printStackTrace();}}

请添加图片描述

http://www.lryc.cn/news/213199.html

相关文章:

  • FOC系列(二)----继续学习DRV8301芯片
  • A. Directional Increase -前缀和与差分理解 + 思维
  • openpnp - java调试环境 - 最好只保留一套jdk环境
  • AI技术的钓鱼邮件有多强
  • vue/react项目刷新页面出现404报错的原因及解决办法
  • 黑客技术(网络安全)——如何高效学习
  • 53.MongoDB分片集群高级集群架构详解
  • Servlet 上下文参数
  • ChatGPT正在测试原生文件分析功能,DALL·E 3能P图啦!
  • 三相马达的电机故障维护
  • 【易售小程序项目】后端部署、Uniapp项目Web部署
  • prometheus监控kafka
  • 【STL】:list用法详解
  • SQL Wildcards 通配符
  • 入门必学 | R语言for循环的常规应用
  • metaRTC集成flutter ui demo编译指南
  • int怎么转成QString?
  • JavaScript进阶(二十九): 走近 es6 之 new.target
  • JVM虚拟机:堆结构的逻辑分区
  • RabbitMQ学习02
  • android中的Package安装、卸载、更新替换流程
  • 思维训练第三课 反意疑问句
  • nvm安装步骤
  • 关于比较级(内含名词比较级)
  • 【算法|动态规划 | 线性dp | 最长上升子序列模型No.1】AcWing1017.怪盗基德的滑翔翼 AcWing1014.登山
  • 2023年道路运输企业主要负责人证模拟考试题库及道路运输企业主要负责人理论考试试题
  • Linux学习第26天:异步通知驱动开发: 主动
  • SpringBoot的核心配置:YAML概述、基础语法;JSR303数据校验;多环境切换
  • 把Qt6.2.4内置的标签打印了一遍
  • element-ui 表单校验・大全