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

Java多线程的几种常见写法

多线程的几种写法

1)继承Thread

class MyThread extends Thread{@Overridepublic void run(){while(true){System.out.println("hello Thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}}
public class Demo1 {public static void main(String[] args) {Thread t = new MyThread();t.start();while (true) {System.out.println("main");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

2)通过实现Runnable接口来实现

package Thread;
class MyRunnable implements Runnable{@Overridepublic void run() {while (true) {System.out.println("hello Thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}}
public class Demo2 {public static void main(String[] args) {Thread t=new Thread(new MyRunnable());t.start();while(true){System.out.println("main");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

3)匿名内部类

package Thread;public class Demo3 {public static void main(String[] args) {Thread t=new Thread(){@Overridepublic void run(){while(true){System.out.println("hello thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}};t.start();while(true){System.out.println("main");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}}
}

4)匿名内部类,针对Runnable

package Thread;public class Demo4 {public static void main(String[] args) {Thread t=new Thread(new MyRunnable(){@Overridepublic void run(){while(true){System.out.println("Thread");}}});t.start();while(true){System.out.println("main");}}
}

5)使用lambda表达式,lambda本质上就是针对匿名内部类的平替

package Thread;import org.w3c.dom.ls.LSOutput;public class Demo5 {public static void main(String[] args) throws InterruptedException {Thread t = new Thread(() -> {try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}});t.start();Thread.sleep(500);System.out.println(t.isAlive());}
}

上述的5种写法,本质上都是

1)要把线程执行的任务内容表示出来

2)通过Thread的start来创建/启动系统中的线程(Thread对象和操作系统中的线程是一一对象的关系)

catch语句中的代码

这个throw是继续再抛出新的异常

 try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}

这个是打印异常调用栈

try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}

2)再main方法中处理sleep有两种选择

1,throws

2,try catch

在线程的run中就只有一个选择了只能try catch,因为重写的时候,就要求方法的签名得是一样的

是否后台线程isDaemon()

关于线程各种属性的设置,都要放到start之前,一旦线程已经启动,开弓没有回头箭,再设置就来不及了

package Thread;import org.w3c.dom.ls.LSOutput;public class Demo5 {public static void main(String[] args) throws InterruptedException {Thread t = new Thread(() -> {try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}});
t.isDaemon();t.start();Thread.sleep(500);}
}

是否存活isAlive()

package Thread;import org.w3c.dom.ls.LSOutput;public class Demo5 {public static void main(String[] args) throws InterruptedException {Thread t = new Thread(() -> {try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}});t.start();Thread.sleep(4000);System.out.println(t.isAlive());}
}

是否中断isInterrupted()

1)第一种纯自己实现

需要让需要终止的线程的入口方法尽快执行结束(跳出循环,还是尽快return 都无所谓)

package Thread;public class Demo6 {private static Boolean isRunning =true;public static void main(String[] args) throws InterruptedException {Thread t=new Thread(() ->{while(isRunning){System.out.println("Thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println("线程结束了");});t.start();System.out.println("main");Thread.sleep(5000);isRunning=false;System.out.println("变量结束");}
}

2)第二种

使用Thread提供的interrupt方法和isInterruptted方法来实现上述的效果,实际上Thread里面内置了一个,使用内置的标志位,功能要更强大

package Thread;public class Demo7 {public static void main(String[] args) throws InterruptedException {Thread t=new Thread(() ->{while(!Thread.currentThread().isInterrupted()){System.out.println("Thread");try {Thread.sleep(1000);} catch (InterruptedException e) {throw new RuntimeException(e);}}});t.start();t.interrupt();Thread.sleep(5000);System.out.println("结束进程");}
}

 当使用了Interrupt方法之后,此时,要不要结束,都是t线程自己决定的!!!

如果代码没有sleep,确实是直接修改了标志位就完了,有sleep,并且是触发Interrupt的时候,线程正在sleep,sleep被唤醒的同时,就会清楚刚才的标志位(又改回false)


http://www.mrgr.cn/news/66637.html

相关文章:

  • window10解决 docker is starting 问题
  • CSS中常见的两列布局、三列布局、百分比和多行多列布局!
  • 信息技术的发展趋势与挑战
  • 正弦波形在示波器上“跑动”的原因及解决办法
  • 江协科技STM32学习- P40 硬件SPI读写W25Q64
  • ubuntu20.04 加固方案-设置重复登录失败后锁定时间限制
  • w023基于web学生宿舍管理系统的设计与开发
  • 谈谈“项目复盘会议”怎么组织
  • 空间解析几何6:空间圆柱体的离散化表示【附MATLAB代码】
  • GB/T 28046.3-2011 道路车辆 电气及电子设备的环境条件和试验 第3部分:机械负荷(10)
  • 独孤思维:图书电商远程诊断,差点晕倒
  • Qt——常用控件
  • STM32F405RGT6单片机原理图、PCB免费分享
  • 让性能提升56%的Vue3.5响应式重构之“版本计数”
  • 人工智能技术的未来展望:变革行业、优化生活与工作方式的无限可能
  • 高清美景风景视频素材网站推荐
  • 制定Excel使用规范和指导,提升数据处理的效率和准确性,减少错误和数据丢失的风险
  • Unity网络通信(part3.序列化和反序列化)
  • 自动化生成和发送报告的Python脚本
  • 详细分析SpringMVC中的@RequestPart注解基本知识
  • Leetcode 1526 Minimum Number of Increments on Subarrays to Form a Target Array
  • 计算并联电阻的阻值
  • Github 2024-11-06 C开源项目日报 Top10
  • SOAP Body 元素
  • C++ | Leetcode C++题解之第541题反转字符串II
  • 决策树(部分)