这篇文章主要为大家展示了如何实现Java并发编程线程间通讯,内容简而易懂,希望大家可以学习一下,学习完之后肯定会有收获的,下面让小编带大家一起来看看吧。
在Java中线程间通讯有多种方式,我这里列出一些常用方式,并用代码的方式展示他们是如何实现的:
示例一:
package com.zhi.test; import java.util.concurrent.CountDownLatch; import java.util.concurrent.atomic.AtomicInteger; import org.junit.Test; /** * Java多线程-线程通讯示例<br> * flag作为共享变量JobB执行,notify通知Job执行,CountDownLatch通知主线程执行 * * @author 张远志 * @since 2020年5月4日21:51:24 * */ public class ThreadTest2 { private CountDownLatch latch; private volatile boolean flag = true; private Object lock = new Object(); private AtomicInteger num = new AtomicInteger(0); class JobA implements Runnable { @Override public void run() { synchronized (lock) { flag = false; if (num.get() != 3) { try { lock.wait(); // wait方法会释放锁 } catch (InterruptedException e) { } } System.out.println("任务A收到通知,继续执行作业"); } latch.countDown(); } } class JobB implements Runnable { @Override public void run() { while (flag) { // 保证JobA先申请到锁 } synchronized (lock) { for (int i = 1; i <= 5; i++) { try { Thread.sleep(1000); } catch (InterruptedException e) { } int a = num.incrementAndGet(); System.out.println("任务B第" + i + "次执行,num值为:" + a); if (a == 3) { lock.notify(); // 唤醒JobB线程,notify方法不会释放锁 } } } latch.countDown(); } } @Test public void test() { latch = new CountDownLatch(2); new Thread(new JobA()).start(); new Thread(new JobB()).start(); try { latch.await(); // 保证2个线程都执行完毕 } catch (InterruptedException e) { } } }
结果输出:
任务B第1次执行,num值为:1
任务B第2次执行,num值为:2
任务B第3次执行,num值为:3
任务B第4次执行,num值为:4
任务B第5次执行,num值为:5
任务A收到通知,继续执行作业
示例二:
package com.zhi.test; import java.util.concurrent.CountDownLatch; import java.util.concurrent.locks.LockSupport; import org.junit.Test; /** * Java多线程-线程通讯示例,利用LockSupport * * @author 张远志 * @since 2020年5月4日21:51:24 * */ public class ThreadTest3 { private CountDownLatch latch; private volatile int num = 0; private Thread ta; private Thread tb; class JobA implements Runnable { @Override public void run() { if (num != 3) { LockSupport.park(); } System.out.println("任务A收到通知,继续执行作业"); latch.countDown(); } } class JobB implements Runnable { @Override public void run() { for (int i = 1; i <= 5; i++) { try { Thread.sleep(1000); } catch (InterruptedException e) { } num++; System.out.println("任务B第" + i + "次执行,num值为:" + num); if (num == 3) { LockSupport.unpark(ta); // unpark会立即激活传入线程 } } latch.countDown(); } } @Test public void test() { latch = new CountDownLatch(2); ta = new Thread(new JobA()); tb = new Thread(new JobB()); ta.start(); tb.start(); try { latch.await(); // 保证2个线程都执行完毕 } catch (InterruptedException e) { } } }
以上就是关于如何实现Java并发编程线程间通讯的内容,如果你们有学习到知识或者技能,可以把它分享出去让更多的人看到。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。