Java高级编程—多线程(完整详解线程的三种实现方式、以及守护线程、出让线程、插入线程、线程声明周期等,附有代码+案例)

本文主要是介绍Java高级编程—多线程(完整详解线程的三种实现方式、以及守护线程、出让线程、插入线程、线程声明周期等,附有代码+案例),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

二十八.多线程

28.1线程的三种实现方式

  1. 继承Thread类的方式进行实现
  2. 实现Runnable接口的方式进行实现
  3. 利用Callable接口和Future接口方式实现

28.1.1 第一种

  • 继承Thread类的方式进行实现
1.自己定义一个类继承Thread
2.重写run方法,编写线程执行体
3.创建子类的对象,并用start()方法启动线程
public class Mythread extends Thread{@Overridepublic void run() {//线程要执行代码for (int i = 0; i < 3; i++) {System.out.println(getName()+"你好");}}
}
==================================
public class MythreadTest {public static void main(String[] args) {Mythread t1 = new Mythread();Mythread t2 = new Mythread();t1.setName("线程1:");t2.setName("线程2:");t1.start();t2.start();}
}

28.1.2 第二种

  • 实现Runnable接口的方式进行实现

    1.自己定义一个类实现Runnable接口
    2.重写里面的run方法
    3.创建自己的类的对象
    4.创建一个Thread类的对象,并用start()方法开启线程

public class MyRun implements Runnable{@Overridepublic void run() {for (int i = 0; i < 3; i++) {// 获取到当前线程的对象Thread t = Thread.currentThread();System.out.println(t.getName()+"你好a");}}
}
===================================================public class MyRunTest {public static void main(String[] args) {// 创建字节定义类的对象,表示要执行的任务///即,创建线程要执行的参数对象MyRun m1 = new MyRun();// 创建线程对象Thread t1 = new Thread(m1);Thread t2 = new Thread(m1);//给线程设置名字t1.setName("线程1:");t2.setName("线程2:");//开启线程t1.start();t2.start();}
}

28.1.3 第三种

  • 利用Callable接口和Future接口方式实现

特点:可以获取到多线程运行的结果

1. 创建一个类MyCallable实现Callable接口
2. 重写call (是有返回值的,表示多线程运行的结果)
3. 创建MyCallable的对象(表示多线程要执行的任务)
4. 创建FutureTask的对象(作用管理多线程运行的结果)
5. 创建Thread类的对象,并启动(表示线程)
import java.util.concurrent.Callable;public class MyCallable implements Callable<Integer> {@Overridepublic Integer call() throws Exception {int sum = 0;for (int i = 1; i <= 3; i++) {sum =sum +i;}return sum;}
}
===================================================
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;public class MyCallableTest {public static void main(String[] args) throws ExecutionException, InterruptedException {// 创建MyCallable的对象(表示多线程要执行的任务)MyCallable mc = new MyCallable();// 创建FutureTask的对象(作用管理多线程运行的结果)FutureTask<Integer> ft = new FutureTask<>(mc);// 创建线程对象Thread t1 = new Thread(ft);// 开启线程t1.start();// 获取多线程运行的结果Integer res = ft.get();System.out.println(res);}
}

28.2 常见的成员方法

方法说明
String getName()返回此线程的名称
void setName(String name)设置线程的名字(构造方法也可以设置名字)
static Thread currentThread()获取当前线程的对象
static void sleep(long time)让线程休眠指定的时间,单位为毫秒
setPriority(int newPriority)设置线程的优先级
final int getPriority()获取线程的优先级
final void setDaemon(boolean on)设置为守护线程
public static void yield()出让线程/礼让线程
public final void join()插入线程/插队线程
public class MyRun implements Runnable{@Overridepublic void run() {for (int i = 0; i < 3; i++) {// 获取到当前线程的对象Thread t = Thread.currentThread();try {//休眠多少时间t.sleep(5000);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println(t.getName()+"你好a");}}
}
========================================
public class MyRunTest {public static void main(String[] args) throws InterruptedException {// 创建字节定义类的对象,表示要执行的任务// 创建线程要执行的参数对象MyRun m1 = new MyRun();// 创建线程对象Thread t1 = new Thread(m1);Thread t2 = new Thread(m1);Thread t3 = new Thread(m1,"线程3:");//给线程设置名字t1.setName("线程1:");t2.setName("线程2:");//获取优先级System.out.println(t1.getPriority());//5//设置优先级(默认是5)t1.setPriority(10);//可以先让t1线程先执行完// t1.sleep(5000);t1.start();t2.start();t3.start();}
}
//用构造方法设置线程名字
// 需要子类继承Thread,然后子类用super调用父类Thread的构造方法
public class Mythread extends Thread{public Mythread() {}public Mythread(String name) {super(name);}@Overridepublic void run() {//线程要执行代码for (int i = 0; i < 3; i++) {System.out.println(getName()+"你好");}}
}
=============================================
public class MythreadTest {public static void main(String[] args) {Mythread  t1 = new Mythread("线程1:");Mythread t2 = new Mythread("线程2:");// t1.setName("线程1:");// t2.setName("线程2:");t1.start();t2.start();}
}

28.3 守护线程

final void setDaemon(boolean on)  设置为守护线程
当非守护线程执行结束后,守护线程才陆续结束;守护线程并不会立即结束
public class Mythread1  extends Thread{//非守护线程@Overridepublic void run() {for (int i = 0; i < 3; i++) {System.out.println(getName()+"better..."+i);}}
}
=============================================public class Mythread2 extends Thread{// 守护线程@Overridepublic void run() {for (int i = 0; i < 100; i++) {System.out.println(getName()+"good..."+i);}}
}
=============================================public class MythreadTest {public static void main(String[] args) {//创建线程对象Mythread1 t1 = new Mythread1();Mythread2 t2 = new Mythread2();// 给线程设置名字t1.setName("大树");t2.setName("小草");// 将线程2设置为守护线程//即,当非守护线程1执行结束后,守护线程2才陆续结束,并不会立即结束t2.setDaemon(true);// 开启线程t1.start();t2.start();}
}

28.4 出让线程

public static void yield()   出让线程/礼让线程当某线程1执行结束后,会让当前CPU的执行权,此时多个线程包括线程1会重新抢夺CPU的执行权,让运行的结果尽可能的均匀
public class Mythread1 extends Thread{public Mythread1() {}public Mythread1(String name) { super(name);}@Overridepublic void run() {for (int i = 0; i < 5; i++) {System.out.println(getName()+"...");//设置为出让线程/礼让线程//表示出让当前CPU的执行权Thread.yield();}}
}
=============================================public class MyThreadTest {public static void main(String[] args) {Mythread1 t1 = new Mythread1("线程1:");Mythread1 t2 = new Mythread1("线程2:");t1.start();t2.start();}
}

28.5 插入线程

public final void join()          
插入线程/插队线程   表示插入当前线程之前比如有线程1 和线程2, 在抢夺CPU的执行权,如果线程2抢到,线程2执行,如果将线程1设置为插入线程,则表示当线程1执行结束后,线程2 才会执行
public class MyThread  extends Thread{@Overridepublic void run() {for (int i = 0; i < 5; i++) {System.out.println(getName()+"..."+i);}}
}
=============================================
public class MyThreaTest {public static void main(String[] args) throws InterruptedException {MyThread t1 = new MyThread();t1.setName("线程1:");t1.start();//表示把t1这个线程,插入到当前线程之前。//t1:线程1//当前线程: main线程t1.join();// 执行在main线程当中for (int i = 0; i < 10; i++) {System.out.println("man线程...");}}
}

28.6 线程生命周期

(图片来自B站Java视频)
在这里插入图片描述

问:sleep方法会让线程睡眠,睡眠时间结束后,立马会执行下面的代码么?

答:不会,因为睡眠结束后,会进入就绪状态,进行CPU的抢夺,抢到CPU 的执行权后才会进入运行状态。

28.7 同步代码块

把操作共享数据的代码锁起来

格式synchronized(){操作共享数据的代码
}

共有100张券,而有3个销售出售,请设计一个程序模拟该出售过程

public class MyThread extends Thread {// 表示这个类所有的对象,都共享ticket数据static int ticket=0;//0-99// 锁对象,一定是唯一的,即 表示obj被共享static Object obj = new Object();@Overridepublic void run() {while (true) {// 同步代码块// obj 可换成 MyThread.classsynchronized (obj) {if (ticket < 100) {try {Thread.sleep(10);} catch (InterruptedException e) {throw new RuntimeException(e);}ticket++;System.out.println(getName() + "出售第" +                      ticket + "个东西");} else {break;}}}}// ending.....
}
==================================public class MyThreadTest {public static void main(String[] args) {// 创建线程对象MyThread t1= new MyThread();MyThread t2 = new MyThread();MyThread t3 = new MyThread();// 给线程设置名字t1.setName("A:");t2.setName("B:");t3.setName("C:");// 开启线程t1.start();t2.start();t3.start();}
}

28.8 同步方法

把synchronized关键字加到方法上

格式
修饰符 synchronized 返回值类型 方法名(方法参数){....
}

特点:

  • 同步方法是锁住方法里的所有代码

  • 锁对象不能自己指定

    非静态 :this

    静态: 当前类的字节码文件对象

需求:

共有100张券,而有3个销售出售,请设计一个程序模拟该出售过程
利用同步方法完成
(技巧:先写成同步代码块,再改成成同步方法)

public class MyRunnable implements  Runnable{// 此处static可以省略不写//因为MyRunnable只创建了一次...static int stick =0;//0-99@Overridepublic void run() {while (true){if (method()) break;}}//ctrl + alt +m ;抽取成方法//方法是非静态的,所以锁对象是this,指的是mr,mr是唯一的private  synchronized boolean method() {if (stick == 100){return true;}else {stick++;String name = Thread.currentThread().getName();System.out.println(name+"出售第"+stick+"个东西");}return false;}
}
==================================public class MyRunnableTest {public static void main(String[] args) {//创建线程要执行的参数对象,即 任务MyRunnable mr = new MyRunnable();// 创建线程对象,(代表三个销售)Thread t1 = new Thread(mr);Thread t2 = new Thread(mr);Thread t3 = new Thread(mr);// 给线程设置名字t1.setName("A:");t2.setName("B:");t3.setName("C:");//开启线程t1.start();t2.start();t3.start();}
}

这篇关于Java高级编程—多线程(完整详解线程的三种实现方式、以及守护线程、出让线程、插入线程、线程声明周期等,附有代码+案例)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1141653

相关文章

Java中流式并行操作parallelStream的原理和使用方法

《Java中流式并行操作parallelStream的原理和使用方法》本文详细介绍了Java中的并行流(parallelStream)的原理、正确使用方法以及在实际业务中的应用案例,并指出在使用并行流... 目录Java中流式并行操作parallelStream0. 问题的产生1. 什么是parallelS

MySQL数据库双机热备的配置方法详解

《MySQL数据库双机热备的配置方法详解》在企业级应用中,数据库的高可用性和数据的安全性是至关重要的,MySQL作为最流行的开源关系型数据库管理系统之一,提供了多种方式来实现高可用性,其中双机热备(M... 目录1. 环境准备1.1 安装mysql1.2 配置MySQL1.2.1 主服务器配置1.2.2 从

C++中unordered_set哈希集合的实现

《C++中unordered_set哈希集合的实现》std::unordered_set是C++标准库中的无序关联容器,基于哈希表实现,具有元素唯一性和无序性特点,本文就来详细的介绍一下unorder... 目录一、概述二、头文件与命名空间三、常用方法与示例1. 构造与析构2. 迭代器与遍历3. 容量相关4

Java中Redisson 的原理深度解析

《Java中Redisson的原理深度解析》Redisson是一个高性能的Redis客户端,它通过将Redis数据结构映射为Java对象和分布式对象,实现了在Java应用中方便地使用Redis,本文... 目录前言一、核心设计理念二、核心架构与通信层1. 基于 Netty 的异步非阻塞通信2. 编解码器三、

C++中悬垂引用(Dangling Reference) 的实现

《C++中悬垂引用(DanglingReference)的实现》C++中的悬垂引用指引用绑定的对象被销毁后引用仍存在的情况,会导致访问无效内存,下面就来详细的介绍一下产生的原因以及如何避免,感兴趣... 目录悬垂引用的产生原因1. 引用绑定到局部变量,变量超出作用域后销毁2. 引用绑定到动态分配的对象,对象

Linux kill正在执行的后台任务 kill进程组使用详解

《Linuxkill正在执行的后台任务kill进程组使用详解》文章介绍了两个脚本的功能和区别,以及执行这些脚本时遇到的进程管理问题,通过查看进程树、使用`kill`命令和`lsof`命令,分析了子... 目录零. 用到的命令一. 待执行的脚本二. 执行含子进程的脚本,并kill2.1 进程查看2.2 遇到的

MyBatis常用XML语法详解

《MyBatis常用XML语法详解》文章介绍了MyBatis常用XML语法,包括结果映射、查询语句、插入语句、更新语句、删除语句、动态SQL标签以及ehcache.xml文件的使用,感兴趣的朋友跟随小... 目录1、定义结果映射2、查询语句3、插入语句4、更新语句5、删除语句6、动态 SQL 标签7、ehc

SpringBoot基于注解实现数据库字段回填的完整方案

《SpringBoot基于注解实现数据库字段回填的完整方案》这篇文章主要为大家详细介绍了SpringBoot如何基于注解实现数据库字段回填的相关方法,文中的示例代码讲解详细,感兴趣的小伙伴可以了解... 目录数据库表pom.XMLRelationFieldRelationFieldMapping基础的一些代

一篇文章彻底搞懂macOS如何决定java环境

《一篇文章彻底搞懂macOS如何决定java环境》MacOS作为一个功能强大的操作系统,为开发者提供了丰富的开发工具和框架,下面:本文主要介绍macOS如何决定java环境的相关资料,文中通过代码... 目录方法一:使用 which命令方法二:使用 Java_home工具(Apple 官方推荐)那问题来了,

JDK21对虚拟线程的几种用法实践指南

《JDK21对虚拟线程的几种用法实践指南》虚拟线程是Java中的一种轻量级线程,由JVM管理,特别适合于I/O密集型任务,:本文主要介绍JDK21对虚拟线程的几种用法,文中通过代码介绍的非常详细,... 目录一、参考官方文档二、什么是虚拟线程三、几种用法1、Thread.ofVirtual().start(