2.什么是线程间的通信？怎么实现线程通信

2.1什么是线程通信以及实现步骤

线程间通信的模型有两种：共享内存和消息传递
线程通信其实就是，实现线程的交替工作，并传递信息

线程间的通信具体步骤：（涉及上中下部）

创建资源类，在资源类中船舰属性和操作方法

在资源类操作方法：判断、操作、通知

创建多个线程，调用资源类的操作方法

防止虚拟唤醒问题（if 判读，只会判断一次）

2.2 synchronized案例

操作线程的时候，等待线程使用wait()
通知另外的线程操作用notify()、notifyAll()
假设有两个线程，该线程在执行过程中，判断值（不是该值等待，让其他线程抢），操作值，通知另外一个线程的调度

实现两个线程对num 这个值操作，一个线程加1，一个线程减1，交替实现多次

//第一步 创建资源类，定义属性和操作方法
class Share {//初始值private int num = 0;//+1的方法public synchronized void incr() throws InterruptedException {//第二步 判断 干活 通知if(number != 0) { //判断number值是否是0，如果不是0，等待this.wait(); //在哪里睡，就在哪里醒}//如果number值是0，就+1操作number++;System.out.println(Thread.currentThread().getName()+" :: "+num);//通知其他线程this.notifyAll(); //注意这里的通知是随机的，就是只能通知全部}//-1的方法public synchronized void decr() throws InterruptedException {//判断if(number != 1) {this.wait();}//干活number--;System.out.println(Thread.currentThread().getName()+" :: "+number);//通知其他线程this.notifyAll();}
}public class ThreadDemo1 {//第三步 创建多个线程，调用资源类的操作方法public static void main(String[] args) {Share share = new Share();//创建线程new Thread(()->{for (int i = 1; i <=10; i++) {try {share.incr(); //+1} catch (InterruptedException e) {e.printStackTrace();}}},"AA").start();new Thread(()->{for (int i = 1; i <=10; i++) {try {share.decr(); //-1} catch (InterruptedException e) {e.printStackTrace();}}},"BB").start();}
}

可以看到，这时，代码是交替进行的一个 +1 一个线程 -1

但是我们考虑如果同时，分别两个线程做加减，那会怎么样呢？

虚假唤醒： wait 是在哪里睡，在哪里被唤醒只做了一次判断虚假唤醒放在while if 判断，只会判断一次所以改为while ；循环判断，就会解决虚假唤醒；从而解决这个错误

2.3 Lock案例

使用lock先要创建锁的对象以及通知的对象
放置在资源类中

private Lock lock= new ReentrantLock();   //创建可重锁private Condition  condition= lock.newCondition();//他能操作的对象

上锁 lock.lock();
解锁 lock.unlock();
以下都为 condition类：
唤醒所有等待的线程signalAll()，带上类名condition.signalAll();
唤醒一个等待线程signal()，带上类名，condition.signal();
造成当前线程在接到信号或者被中断之前一直处于等待状态await()，带上类名，condition.await();

Lock 实现的代码基本是相同的，注意上锁和解锁是自己手动做的工作，最终都要在finally 解锁

如果不解锁，会影响下面以后的线程

class LShare{
//这是共享资源，注意锁的创建和使用，其他的和上面基本相同private int num=0;private Lock lock= new ReentrantLock();   //创建可重锁private Condition  condition= lock.newCondition();//创建操作的方法public void add (){lock.lock();   //首先 手动上锁；try {  //判断，干活，通知while (num!=0){condition.await();//它使用的是这个对象 调用方法 等待}num++;System.out.println( Thread.currentThread().getName()+" 干活完成 ："+num);condition.signalAll(); //这个通知方法} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock(); //最终不管出现什么错误，都会解锁}}

这就实现了线程间的通信，，即他们能够根据信息，完成交替的工作

下面就是学如何定制通信？（交替进行线程，但是每个线程的工作是改变的）

2.什么是线程间的通信？怎么实现线程通信相关推荐

1线程概念：线程和进程之间的关系，线程间可共享资源，线程间非共享资源，线程的优缺点
1线程概念 1.1什么是线程 1.1.2线程和进程的关系 1.轻量级进程(light-weightprocess),也有PCB,创建线程使用底层函数和进程一样,都是clone. 2.从内核里看进 ...
C++编程思想第2卷第11章并发线程间协作用队列解决线程处理的问题适当地进行烘烤
解决ToastOMatic.cpp存在的问题可以在加工期间使用TQueue管理烤面包需要实际的烤面包对象它们保持显示了其状态 //: C11:ToastOMaticMarkII.cpp {Run ...
Java 多线程（七）线程间的通信
Java 多线程(七) 线程间的通信--wait及notify方法线程间的相互作用线程间的相互作用:线程之间需要一些协调通信,来共同完成一件任务. Object类中相关的方法有两个notify方法 ...
java面试-Java并发编程(六)——线程间的通信
多条线程之间有时需要数据交互,下面介绍五种线程间数据交互的方式,他们的使用场景各有不同. 1. volatile.synchronized关键字 PS:关于volatile的详细介绍请移步至:Java ...
【JUC】第二章线程间通信、集合的线程安全
第二章线程间通信.集合的线程安全文章目录第二章线程间通信.集合的线程安全一.线程间通信 1.介绍 2.synchronized 方案 3.Lock 方案 4.定制化线程通信二.集合的线程安 ...
c语言线程通信方式,线程间通信及同步方法介绍
线程间如何通信/同步?此前小编给大家介绍了进程间通信的方法,于是一些伙伴又好奇线程间的通信及同步方法,没关系,下面小编就继续给大家科普下线程间通信及同步的方法. 线程间通信及同步方法介绍: 一.线程间 ...
线程间通信方式Linux,线程间的通信、同步方式与进程间通信方式
1.线程间的通信方式使用全局变量主要由于多个线程可能更改全局变量,因此全局变量最好声明为volatile 使用消息实现通信在Windows程序设计中,每一个线程都可以拥有自己的消息队列(UI线程 ...
wxWidgets：线程间和进程间通信
wxWidgets:线程间和进程间通信 wxWidgets:线程间和进程间通信线程间通信将事件发送到主线程 - 仅限 wxWidgets 3 向主线程发送事件向主线程发送自定义事件双向通讯新 ...
Python线程间通信方式
1.python多线程 #! /usr/bin/evn python3 # --*-- coding: utf-8 --*--#该实例反编译来说明函数执行流程 import disdef add(a) ...
Java线程间的通信方式
文章目录线程间通信的定义一.等待-通知 (1)等待-通知机制的相关方法: (2)注意事项: (4)notify()方法的核心原理 (5)等待-通知机制的经典范式 (6)Thread.join() ...

2.什么是线程间的通信？怎么实现线程通信

2.1什么是线程通信以及实现步骤

2.2 synchronized案例

2.3 Lock案例

2.什么是线程间的通信？怎么实现线程通信相关推荐

最新文章

热门文章

2.什么是线程间的通信 ？怎么实现线程通信

2.1什么是线程通信以及实现步骤

2.2 synchronized案例

2.3 Lock案例

2.什么是线程间的通信 ？怎么实现线程通信相关推荐

最新文章

热门文章

2.什么是线程间的通信？怎么实现线程通信

2.什么是线程间的通信？怎么实现线程通信相关推荐