锐客网

  1. 首页 > 睿知 > >

实现java线程通信的几种方式 讲解java多线程共享数据

生活知识经验知识

开发中不免会遇到需要所有子线程执行完毕通知主线程处理某些逻辑的场景 。
或者是线程 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;}@Overridepublicvoidrun(){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;}@Overridepublicvoidrun(){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+-+奇数93t1+-+偶数94t2+-+奇数95t1+-+偶数96t2+-+奇数97t1+-+偶数98t2+-+奇数99t1+-+偶数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(){@Overridepublicvoidrun(){LOGGER.info("running");try{Thread.sleep(3000);}catch(InterruptedExceptione){e.printStackTrace();}}});Threadt2=newThread(newRunnable(){@Overridepublicvoidrun(){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;@Overridepublicvoidrun(){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;}}

推荐阅读


上一篇：有什么电影适合和男朋友一起看？

下一篇：早上起来在学校公共卫生间上厕所最尴尬事情,你有过吗？