JAVA多线程间通讯常用实现方法解析
如何实现线程间通讯,有如下三种方法:
1、使用Semaphore (信号量)类来控制线程的等待和释放
功能:三个线程 a 、b 、c 并发运行,b,c 需要 a 线程的数据怎么实现
分析:考虑到多线程的不确定性, 因此我们不能确保 ThreadA 就一定先于 ThreadB 和 ThreadC 前执行,就算 ThreadA先执行了, 我们也无法保证 ThreadA 什么时候才能将变量 num 给初始化完成。 因此我们必须让 ThreadB 和 Thread去等待 ThreadA 完成任何后发出的消息
解决方案:解决上面的难题我能想到的两种方案,一是使用纯 Java API 的 Semaphore 类来控制线程的等待和释放,二是使用 Android 提供的 Handler 消息机制,此处不举列说明;
import java.util.concurrent.Semaphore; public class ThreadCommunication { private static int num; /** * 定义一个信号量,该类内部维持了多个线程锁,可以阻塞多个线程,释放多个线程, 线程的阻塞和释放是通过 permit 概念来实现的。线程通过semaphore.acquire()方法获取 permit,如果当前 semaphore 有 permit 则分配给该线程,如果没有则阻塞该线程直到 semaphore 调用 release()方法释放 permit。 * 构造函数 Semaphore(int permits) : 创建具有给定的许可数和非公平的公平设置的 Semaphore */ private static Semaphore semaphore = new Semaphore(0);//表示初始时没有可用的permit public static void main(String[] args) { Thread threadA = new Thread(new Runnable() { public void run() { try { // 模拟耗时操作之后初始化变量 num Thread.sleep(1000); num = 1; // 初始化完参数后释放两个 permit semaphore.release(2); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "获取到 num 的值为:" + num); } },"threadA"); Thread threadB = new Thread(new Runnable() { public void run() { try { // 获取 permit,如果 semaphore 没有可用的 permit 则等待,如果有则消耗一个 semaphore.acquire(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "获取到 num 的值为:" + num); } },"threadB"); Thread threadC = new Thread(new Runnable() { public void run() { try { // 获取 permit,如果 semaphore 没有可用的 permit 则等待,如果有则消耗一个 semaphore.acquire(); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "获取到 num 的值为:" + num); } },"threadC"); // 同时开启 3 个线程 threadA.start(); threadB.start(); threadC.start(); } }
运行结果:
threadA获取到 num 的值为:1
threadB获取到 num 的值为:1
threadC获取到 num 的值为:1
2、发送信号的一个简单方式是在共享对象的变量里设置信号值,通过join方法实现
线程间通信可以通过发送信号,发送信号的一个简单方式是在共享对象的变量里设置信号值(并提供set和get方法)。线程 A 在一个同步块里设置 boolean 型成员变量 hasDataToProcess 为 true,线程 B 也在同步块里读取 hasDataToProcess这个成员变量。
package threadLearning.waitSleepExchage; public class ThreadCommunication2 { // 共享的变量 private boolean hasDataToProcess = false; // 取值 public boolean getHasDataToProcess() { return hasDataToProcess; } // 存值 public void setHasDataToProcess(boolean hasDataToProcess) { this.hasDataToProcess = hasDataToProcess; } public static void main(String[] args) { // 同一个对象 final ThreadCommunication2 my = new ThreadCommunication2(); // 线程 1 设置 hasDataToProcess 值为 true final Thread t1 = new Thread(new Runnable() { public void run() { my.setHasDataToProcess(true); } }); t1.start(); // 线程 2 取这个值 hasDataToProcess Thread t2 = new Thread(new Runnable() { public void run() { try { // 等待线程 1 完成然后取值 t1.join(); } catch (InterruptedException e) { e.printStackTrace(); } my.getHasDataToProcess(); System.out.println("t1 改变以后的值:" + my.getHasDataToProcess()); } }); t2.start(); } }
运行结果为:t1 改变以后的值:true
3、发送信号的一个简单方式是在共享对象的变量里设置信号值,通过wait方法实现
项目功能简介:
线程A 对Person的姓名和年龄进行赋值,线程B对获取同一个Person的姓名和年龄并输出。
如果线程A没有赋值完成,那么线程B则处于等待状态,在线程A赋值完成后唤醒线程B进行输出
如果线程B没有输出完成,那么线程A则处于等待状态,在线程B输出完成后唤醒线程A进行赋值
class Person { String name; String gender; boolean flag = false;// (标记)默认不输出,即先进行输入后才能输出 } class Input implements Runnable { private Person p; private int n = 0; public Input(Person p) { this.p = p; } public void run() { // 别忘了while(true)!! while (true) { synchronized (p) {// 两个Runnable用同一个Person初始化,就可保证p是同一个且唯一 if (p.flag) { try { p.wait(); } catch (InterruptedException e) { } } // not "else" if (n == 0) { p.name = "Jason"; p.gender = "男"; } else { p.name = "Lily"; p.gender = "女"; } n = (n + 1) % 2;//是的n在1和0之间切换取值 p.flag = true;// 修改标志位 p.notify();// 唤醒另一个 } } } } class Output implements Runnable { private Person p; public Output(Person p) { this.p = p; } public void run() { // 别忘了while(true)!! while (true) { synchronized (p) { // 仍然是判断标志位,和上面的线程轮流等待,唤醒 if (!p.flag) { try { p.wait(); } catch (InterruptedException e) { } } System.out.println(p.name + "..." + p.gender); // 别忘了改变标志位和唤醒另一个 p.flag = false;// 让自己回来等待 p.notify();// 同一个锁,唤醒锁上的另一个线程 }// 问题:一个线程再次进入锁,等待,另一个进程在此前唤醒了,此时能进入锁执行吗?-->能,wait()即会释放锁,也释放执行资格! } } } public class WaitSleepTest1 { public static void main(String[] args) { Person p = new Person(); new Thread(new Input(p)).start(); new Thread(new Output(p)).start(); } }
运行结果为:
Jason...男 Lily...女 Jason...男 Lily...女 Jason...男 Lily...女 Jason...男 Lily...女 Jason...男 Lily...女 Jason...男 ......
备注:
- wait和sleep的区别:
- wait():释放资源,释放锁
- sleep():释放资源,不释放锁
- wait():Object的方法,用在同步当中,是同步锁的方法,以锁控制线程
- sleep():线程类Thread本身的静态方法
- wait(),notify(),notifyAll()方法是用在同步当中的:必须是同步当中的同一把锁操作线程。
所以这几个方法是Object的方法。试想想不在同步中的多线程,由于抢夺执行权结果不定,控制无意义。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持猪先飞。
相关文章
- 这篇文章主要介绍了如何利用java语言实现经典《复杂迷宫》游戏,文中采用了swing技术进行了界面化处理,感兴趣的小伙伴可以动手试一试...2022-02-01
C# WinForm多线程解决界面卡死问题的完美解决方案,使用BeginInvoke
问题描述:当我们的界面需要在程序运行中不断更新数据时,当一个textbox的数据需要变化时,为了让程序执行中不出现界面卡死的现像,最好的方法就是多线程来解决一个主线程来创建界...2020-06-24java 运行报错has been compiled by a more recent version of the Java Runtime
java 运行报错has been compiled by a more recent version of the Java Runtime (class file version 54.0)...2021-04-01- 这篇文章主要介绍了在java中获取List集合中最大的日期时间操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-08-15
- 这篇文章主要介绍了教你怎么用Java获取国家法定节假日,文中有非常详细的代码示例,对正在学习java的小伙伴们有非常好的帮助,需要的朋友可以参考下...2021-04-23
- 这篇文章主要介绍了Java如何发起http请求的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-03-31
- 这篇文章主要介绍了C#停止线程的方法,实例分析了C#正确停止线程的实现技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25
- 今天小编就为大家分享一篇关于C#开启线程的四种方式示例详解,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧...2020-06-25
- 说起C#和Java这两门语言(语法,数据类型 等),个人以为,大概有90%以上的相似,甚至可以认为几乎一样。但是在工作中,我也发现了一些细微的差别...2020-06-25
- 这篇文章主要介绍了解决Java处理HTTP请求超时的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-03-29
- 这篇文章主要介绍了C# 线程相关知识,文中讲解非常细致,代码帮助大家更好的理解和学习,感兴趣的朋友可以了解下...2020-11-03
- 这篇文章主要介绍了c# 多线程处理多个数据的方法,帮助大家更好的理解和学习使用c#,感兴趣的朋友可以了解下...2021-03-31
- 这篇文章主要介绍了C#实现跨线程操作控件方法,主要采用异步访问方式实现,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了java 判断两个时间段是否重叠的案例,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-08-15
java 画pdf用itext调整表格宽度、自定义各个列宽的方法
这篇文章主要介绍了java 画pdf用itext调整表格宽度、自定义各个列宽的方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-01-31- 这篇文章主要介绍了超简洁java实现双色球若干注随机号码生成(实例代码),本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-04-02
- 这篇文章主要介绍了Java生成随机姓名、性别和年龄的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-10-01
- 这篇文章主要介绍了C#基于委托实现多线程之间操作的方法,实例分析了C#的委托机制与多线程交互操作的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了java正则表达式判断前端参数修改表中另一个字段的值,需要的朋友可以参考下...2021-05-07
Java使用ScriptEngine动态执行代码(附Java几种动态执行代码比较)
这篇文章主要介绍了Java使用ScriptEngine动态执行代码,并且分享Java几种动态执行代码比较,需要的朋友可以参考下...2021-04-15