av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

Java并發編程線程間通訊實現過程詳解

瀏覽:8日期:2022-09-01 17:18:04

在Java中線程間通訊有多種方式,我這里列出一些常用方式,并用代碼的方式展示他們是如何實現的:

共享變量 wait, notify,notifyAll(這3個方法是Object對象中的方法,且必須與synchronized關鍵字結合使用) CyclicBarrier、CountDownLatch 利用LockSupport Lock/Condition機制 管道,創建管道輸出流PipedOutputStream和管道輸入流PipedInputStream

示例一:

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
相關文章:
主站蜘蛛池模板: 久久综合久色欧美综合狠狠 | 欧美在线视频一区二区 | h视频在线看| 羞羞视频网站免费观看 | 古装人性做爰av网站 | 天天久久 | 日本韩国电影免费观看 | 1级毛片| 狠狠操av | 中文在线播放 | 在线观看视频91 | 日韩波多野结衣 | 国产成人精品久久 | 午夜丁香视频在线观看 | 亚洲国产欧美国产综合一区 | 亚洲欧美精品 | 亚洲毛片在线观看 | 国产精品亚洲视频 | 国内自拍视频在线观看 | 久久国内 | 一级毛片在线播放 | 欧美中文一区 | 97超碰成人| 在线不卡视频 | 亚洲国产中文字幕 | 91精品国产高清一区二区三区 | 911影院| 欧美一级免费观看 | 手机在线一区二区三区 | 成人激情视频 | 亚洲国产精品日本 | 国产一在线 | 久久综合一区二区 | 日韩在线播放视频 | 中文字幕第一页在线 | 欧美一区二 | 中文字幕一页二页 | 国产精品资源在线 | 久久久www成人免费精品 | 久久久久久久国产精品影院 | 在线免费观看黄视频 |