线程间通信(线程间的通信方式三种)
线程间通信(线程间的通信方式三种)
前言
开发中不免会遇到需要所有子线程执行完毕通知主线程处理某些逻辑的场景。
或者是线程 A 在执行到某个条件通知线程 B 执行某个操作。
可以通过以下几种方式实现:等待通知机制
等待通知模式是 Java 中比较经典的线程通信方式。
两个线程通过对同一对象调用等待 wait() 和通知 notify() 方法来进行通讯。
如两个线程交替打印奇偶数:publicclassTwoThreadWaitNotify{privateintstart=1;privatebooleanflag=false;publicstaticvoidmain(String[]args){ TwoThreadWaitNotifytwoThread=newTwoThreadWaitNotify(); Threadt1=newThread(newOuNum(twoThread)); t1.setName("A"); Threadt2=newThread(newJiNum(twoThread)); t2.setName("B"); t1.start(); t2.start(); }/** *偶数线程 */ publicstaticclassOuNumimplementsRunnable{privateTwoThreadWaitNotifynumber;publicOuNum(TwoThreadWaitNotifynumber){this.number=number; }@Override publicvoidrun(){while(number.start<=100){synchronized(TwoThreadWaitNotify.class){ System.out.println("偶数线程抢到锁了");if(number.flag){ System.out.println(Thread.currentThread().getName()+"+-+偶数"+number.start); number.start++; number.flag=false; TwoThreadWaitNotify.class.notify(); }else{try{ TwoThreadWaitNotify.class.wait(); }catch(InterruptedExceptione){ e.printStackTrace(); } } } } } }/** *奇数线程 */ publicstaticclassJiNumimplementsRunnable{privateTwoThreadWaitNotifynumber;publicJiNum(TwoThreadWaitNotifynumber){this.number=number; }@Override publicvoidrun(){while(number.start<=100){synchronized(TwoThreadWaitNotify.class){ System.out.println("奇数线程抢到锁了");if(!number.flag){ System.out.println(Thread.currentThread().getName()+"+-+奇数"+number.start); number.start++; number.flag=true; TwoThreadWaitNotify.class.notify(); }else{try{ TwoThreadWaitNotify.class.wait(); }catch(InterruptedExceptione){ e.printStackTrace(); } } } } } } }
输出结果:t2+-+奇数93 t1+-+偶数94 t2+-+奇数95 t1+-+偶数96 t2+-+奇数97 t1+-+偶数98 t2+-+奇数99 t1+-+偶数100
这里的线程 A 和线程 B 都对同一个对象 TwoThreadWaitNotify.class 获取锁,A 线程调用了同步对象的 wait() 方法释放了锁并进入 WAITING 状态。
B 线程调用了 notify() 方法,这样 A 线程收到通知之后就可以从 wait() 方法中返回。
这里利用了 TwoThreadWaitNotify.class 对象完成了通信。
有一些需要注意:
wait() 、notify()、notifyAll() 调用的前提都是获得了对象的锁(也可称为对象监视器)。
调用 wait() 方法后线程会释放锁,进入 WAITING 状态,该线程也会被移动到等待队列中。
调用 notify() 方法会将等待队列中的线程移动到同步队列中,线程状态也会更新为 BLOCKED
从 wait() 方法返回的前提是调用 notify() 方法的线程释放锁,wait() 方法的线程获得锁。
等待通知有着一个经典范式:
线程 A 作为消费者:
获取对象的锁。
进入 while(判断条件),并调用 wait() 方法。
当条件满足跳出循环执行具体处理逻辑。
线程 B 作为生产者:
获取对象锁。
更改与线程 A 共用的判断条件。
调用 notify() 方法。
伪代码如下://ThreadAsynchronized(Object){while(条件){Object.wait(); }//dosomething}//ThreadBsynchronized(Object){ 条件=false;//改变条件 Object.notify(); }join() 方法privatestaticvoidjoin()throwsInterruptedException{ Threadt1=newThread(newRunnable(){@Override publicvoidrun(){ LOGGER.info("running");try{ Thread.sleep(3000); }catch(InterruptedExceptione){ e.printStackTrace(); } } }); Threadt2=newThread(newRunnable(){@Override publicvoidrun(){ LOGGER.info("running2");try{ Thread.sleep(4000); }catch(InterruptedExceptione){ e.printStackTrace(); } } }); t1.start(); t2.start();//等待线程1终止 t1.join();//等待线程2终止 t2.join(); LOGGER.info("mainover"); }
输出结果:2018-03-1620:21:30.967[Thread-1]INFOc.c.actual.ThreadCommunication-running22018-03-1620:21:30.967[Thread-0]INFOc.c.actual.ThreadCommunication-running2018-03-1620:21:34.972[main]INFOc.c.actual.ThreadCommunication-mainover
在 t1.join() 时会一直阻塞到 t1 执行完毕,所以最终主线程会等待 t1 和 t2 线程执行完毕。
其实从源码可以看出,join() 也是利用的等待通知机制:
核心逻辑:while(isAlive()){wait(0); }
在 join 线程完成后会调用 notifyAll() 方法,是在 JVM 实现中调用,所以这里看不出来。volatile 共享内存
因为 Java 是采用共享内存的方式进行线程通信的,所以可以采用以下方式用主线程关闭 A 线程:publicclassVolatileimplementsRunnable{privatestaticvolatilebooleanflag=true;@Override publicvoidrun(){while(flag){ System.out.println(Thread.currentThread().getName()+"正在运行…"); } System.out.println(Thread.currentThread().getName()+"执行完毕"); }publicstaticvoidmain(String[]args)throwsInterruptedException{ VolatileaVolatile=newVolatile();newThread(aVolatile,"threadA").start(); System.out.println("main线程正在运行"); TimeUnit.MILLISECONDS.sleep(100); aVolatile.stopThread(); }privatevoidstopThread(){ flag=false; } }
输出结果:threadA正在运行…threadA正在运行…threadA正在运行…threadA正在运行…threadA执行完毕
这里的 flag 存放于主内存中,所以主线程和线程 A 都可以看到。
flag 采用 volatile 修饰主要是为了内存可见性,更多内容可以查看这里。CountDownLatch 并发工具
CountDownLatch 可以实现 join 相同的功能,但是更加的灵活。privatestaticvoidcountDownLatch()throwsException{intthread=3;longstart=System.currentTimeMillis();finalCountDownLatchcountDown=newCountDownLatch(thread);for(inti=0;i<thread;i++){newThread(newRunnable(){@Override publicvoidrun(){ LOGGER.info("threadrun");try{ Thread.sleep(2000); countDown.countDown(); LOGGER.info("threadend"); }catch(InterruptedExceptione){ e.printStackTrace(); } } }).start(); } countDown.await();longstop=System.currentTimeMillis(); LOGGER.info("mainovertotaltime={}",stop-start); }
输出结果:2018-03-1620:19:44.126[Thread-0]INFOc.c.actual.ThreadCommunication-threadrun2018-03-1620:19:44.126[Thread-2]INFOc.c.actual.ThreadCommunication-threadrun2018-03-1620:19:44.126[Thread-1]INFOc.c.actual.ThreadCommunication-threadrun2018-03-1620:19:46.136[Thread-2]INFOc.c.actual.ThreadCommunication-threadend2018-03-1620:19:46.136[Thread-1]INFOc.c.actual.ThreadCommunication-threadend2018-03-1620:19:46.136[Thread-0]INFOc.c.actual.ThreadCommunication-threadend2018-03-1620:19:46.136[main]INFOc.c.actual.ThreadCommunication-mainovertotaltime=2012
CountDownLatch 也是基于 AQS(AbstractQueuedSynchronizer) 实现的,更多实现参考 ReentrantLock 实现原理
初始化一个 CountDownLatch 时告诉并发的线程,然后在每个线程处理完毕之后调用 countDown() 方法。
该方法会将 AQS 内置的一个 state 状态 -1 。
最终在主线程调用 await() 方法,它会阻塞直到 state == 0 的时候返回。CyclicBarrier 并发工具privatestaticvoidcyclicBarrier()throwsException{ CyclicBarriercyclicBarrier=newCyclicBarrier(3);newThread(newRunnable(){@Override publicvoidrun(){ LOGGER.info("threadrun");try{ cyclicBarrier.await(); }catch(Exceptione){ e.printStackTrace(); } LOGGER.info("threadenddosomething"); } }).start();newThread(newRunnable(){@Override publicvoidrun(){ LOGGER.info("threadrun");try{ cyclicBarrier.await(); }catch(Exceptione){ e.printStackTrace(); } LOGGER.info("threadenddosomething"); } }).start();newThread(newRunnable(){@Override publicvoidrun(){ LOGGER.info("threadrun");try{ Thread.sleep(5000); cyclicBarrier.await(); }catch(Exceptione){ e.printStackTrace(); } LOGGER.info("threadenddosomething"); } }).start(); LOGGER.info("mainthread"); }
CyclicBarrier 中文名叫做屏障或者是栅栏,也可以用于线程间通信。
它可以等待 N 个线程都达到某个状态后继续运行的效果。
首先初始化线程参与者。
调用 await() 将会在所有参与者线程都调用之前等待。
直到所有参与者都调用了 await() 后,所有线程从 await() 返回继续后续逻辑。
运行结果:2018-03-1822:40:00.731[Thread-0]INFOc.c.actual.ThreadCommunication-threadrun2018-03-1822:40:00.731[Thread-1]INFOc.c.actual.ThreadCommunication-threadrun2018-03-1822:40:00.731[Thread-2]INFOc.c.actual.ThreadCommunication-threadrun2018-03-1822:40:00.731[main]INFOc.c.actual.ThreadCommunication-mainthread2018-03-1822:40:05.741[Thread-0]INFOc.c.actual.ThreadCommunication-threadenddosomething2018-03-1822:40:05.741[Thread-1]INFOc.c.actual.ThreadCommunication-threadenddosomething2018-03-1822:40:05.741[Thread-2]INFOc.c.actual.ThreadCommunication-threadenddosomething
可以看出由于其中一个线程休眠了五秒,所有其余所有的线程都得等待这个线程调用 await() 。
该工具可以实现 CountDownLatch 同样的功能,但是要更加灵活。甚至可以调用 reset() 方法重置 CyclicBarrier (需要自行捕获 BrokenBarrierException 处理) 然后重新执行。线程响应中断publicclassStopThreadimplementsRunnable{@Override publicvoidrun(){while(!Thread.currentThread().isInterrupted()){//线程执行具体逻辑 System.out.println(Thread.currentThread().getName()+"运行中…"); } System.out.println(Thread.currentThread().getName()+"退出…"); }publicstaticvoidmain(String[]args)throwsInterruptedException{ Threadthread=newThread(newStopThread(),"threadA"); thread.start(); System.out.println("main线程正在运行"); TimeUnit.MILLISECONDS.sleep(10); thread.interrupt(); } }
输出结果:threadA运行中…threadA运行中…threadA退出…
可以采用中断线程的方式来通信,调用了 thread.interrupt() 方法其实就是将 thread 中的一个标志属性置为了 true。
并不是说调用了该方法就可以中断线程,如果不对这个标志进行响应其实是没有什么作用(这里对这个标志进行了判断)。
但是如果抛出了 InterruptedException 异常,该标志就会被 JVM 重置为 false。线程池 awaitTermination() 方法
如果是用线程池来管理线程,可以使用以下方式来让主线程等待线程池中所有任务执行完毕:privatestaticvoidexecutorService()throwsException{ BlockingQueue<Runnable>queue=newLinkedBlockingQueue<>(10); ThreadPoolExecutorpoolExecutor=newThreadPoolExecutor(5,5,1,TimeUnit.MILLISECONDS,queue); poolExecutor.execute(newRunnable(){@Override publicvoidrun(){ LOGGER.info("running");try{ Thread.sleep(3000); }catch(InterruptedExceptione){ e.printStackTrace(); } } }); poolExecutor.execute(newRunnable(){@Override publicvoidrun(){ LOGGER.info("running2");try{ Thread.sleep(2000); }catch(InterruptedExceptione){ e.printStackTrace(); } } }); poolExecutor.shutdown();while(!poolExecutor.awaitTermination(1,TimeUnit.SECONDS)){ LOGGER.info("线程还在执行…"); } LOGGER.info("mainover"); }
仪器导购评测(测水质仪器)仪器导购评测(测水质仪器)原创彬彬这厢有礼了20210514202738领导小王,你脖子怎么歪啦?我加班加的,整天对着电脑,没时间运动啊。上面只是举个栗子,不过最近笔者的脖子是真是
最美的女人(真正中国历史上最美的女人是谁?)最美的女人(真正中国历史上最美的女人是谁?)什么西施,貂蝉往后站,什么昭君,玉环不能看。还有妲己和飞燕国家祸乱,终抵不过此女。中国历史上的美女多是记载她的容貌多美!而她有多美记载的
故宫平面图(北京故宫图文详解)故宫平面图(北京故宫图文详解)北京故宫是中国明清两代的皇家宫殿,旧称为紫禁城,位于北京中轴线的中心,是中国古代宫廷建筑之精华。你想看看故宫平面图来总体看看故宫的全貌吗?下面是学习啦
吐纳导引术(龟蛇长寿导引吐纳法)吐纳导引术(龟蛇长寿导引吐纳法)神龟虽寿,犹有竟时,腾蛇乘雾,终为土灰,老骥伏枥,志在千里,烈士暮年,壮心不已,盈缩之期,不但在天,养怡之福,可得永年,幸甚至哉!歌以咏志。这是三国
如何寻找自动刷票软件今天小编要来跟大家聊的话题是如何寻找自动刷票软件,如今很多人对于自动刷票软件都是早有耳闻,特别的那些现在正在参加微信投票活动的参赛者,他们对于刷票软件的需求是非常迫切的,因为大家都
腾讯年终奖(腾讯2021年年终奖)腾讯年终奖(腾讯2021年年终奖)原创MBA智库20210219110207文姜榆木编辑MBA智库琉琉又在热搜榜上看到别人公司的年终奖。2月8日,腾讯的年终阳光普照奖,成为每个职场
奖金所得税计算器(综合所得年度计算器)奖金所得税计算器(综合所得年度计算器)如今的社会发展变得越来越快,因此企业对于员工的待遇也变得越来越好。五险一金年终奖下午茶等等。那么奖金的个人所得税计算方法是怎么样的呢?奖金的个
一分钟速算方法(一分钟速算及十大速算技巧)一分钟速算方法(一分钟速算及十大速算技巧)心算口诀一分钟速算及十大速算技巧(完整版)需要的可以收藏。十个手指,手掌面向自己,从左往右数数。个位比十位大19口诀个位是几弯回几,弯指左
英雄联盟处罚减免功能升级同一个帐号180天内只能有一次处罚减免的申请机会文章来源科技讯近期腾讯游戏安全中心发布了英雄联盟处罚减免功能升级公告2020年10月21号下午15点整开始同一个帐号180天内只能有一次处罚减免的申请机会下面是具体公告内容亲爱的召
古典舞桃夭(舞蹈桃夭教学视频)古典舞桃夭(舞蹈桃夭教学视频)新帝虽然允了陆绎三个月的假期,但陆绎要把手上的琐事,暂时料理完才能带今夏和俩娃安心出去散心,至少要端午节后才能动身了。今夏心道正好,趁着端午佳节,好好
舞蹈节目串词(幼儿园六一节目串词)舞蹈节目串词(幼儿园六一节目串词)一场好的演出,不仅要有好的节目,还要有精彩的节目串词。因为缺少节目串词的演出,总给人一种干巴巴的感觉,而要引起观众共鸣,节目串词很关键。为此,罗老
我爱你西班牙语(小语种学什么最好)我爱你西班牙语(小语种学什么最好)只会用lloveyou,Ilikeyou表白?来点更有趣,更浪漫的学习用西班牙语表白吧。昨天我们学习了用Megustastu(我喜欢你)来表白点击
油泵柱塞(柱塞泵装配图)油泵柱塞(柱塞泵装配图)宁波思承何静202105281508305月28日,宁波思承流体何静摄导读VICKERS威格士PVQ20B2RSS1S21C2112轴向柱塞泵是一种液压系统
施耐庵罗贯中(没想到施耐庵与罗贯中是这种关系)施耐庵罗贯中(没想到施耐庵与罗贯中是这种关系)爱好文学的人都知道,施耐庵水浒传的作者,罗贯中是三国演义作者,这两部小说都属于中国四大名著,每一个中国人都耳熟能详。但是你们知道施耐庵
施耐庵和罗贯中(没想到施耐庵与罗贯中是这种关系?)施耐庵和罗贯中(没想到施耐庵与罗贯中是这种关系?)爱好文学的人都知道,施耐庵水浒传的作者,罗贯中是三国演义作者,这两部小说都属于中国四大名著,每一个中国人都耳熟能详。但是你们知道施
场效应管参数(场效应管的型号参数选择)场效应管参数(场效应管的型号参数选择)MOS管也叫场效应管,是电路中常用的功率器件。根据材料结构不同分为两种N沟道MOS管,P沟道MOS管。电气符号如下图N沟道和P沟道MOS管实际
微波炉电路图(微波炉的整机结构及电路工作原理图)微波炉电路图(微波炉的整机结构及电路工作原理图)一微波炉的外形结构下图所示的是格兰仕微波炉的外形结构,主要由炉门外壳操作面板及显示面板组成。1炉门炉门由耐高温的钢化玻璃和金属网构成
abb变频器工作原理(abb面板改中文)abb变频器工作原理(abb面板改中文)变频小帮手20181114153015ABB变频器一拖一一1拖1PID配置1ABB变频器一拖一接线注1)图压力传感器反馈的信号为电流型,设置
流星雨风暴(流星彩虹风暴)流星雨风暴(流星彩虹风暴)流星雨是大量地外小天体闯入大气层时发出流星闪光的天文现象,这种现象实际上经常发生,由于地球运行的轨道比较固定,所以每年都会有相同的流星雨造访地球。比如,1
数码知识iqoo怎么关闭系统自动更新禁止系统自动更新如今使用IT数码设备的小伙伴们是越来越多了,那么IT数码设备当中是有很多小技巧的,这些技巧很多小伙伴一般都是不知道如何来实用的,就好比最近就有很多小伙伴们想要知道iqoo怎么关闭系
江铃运霸(江铃面包车)江铃运霸(江铃面包车)自主汽车网20200429094523国产车江铃汽车有哪几款?你关注这款车吗?1江铃宝威江铃宝威是在对SUV和皮卡车的优缺点进行深入研究以后推出来的一款全新车
机油更换时间(机油6个月一定要换吗)机油更换时间(机油6个月一定要换吗)如今汽车已经成为人们生活的必需品,为了方便很多人都会选择购买一辆汽车,当然了,汽车买回来之后也需要保养,我们买车的时候车企都会给我们一本汽车保养