資訊專欄INFORMATION COLUMN
摘要：作用屏障攔截，構(gòu)造參數(shù)可以傳遞攔截的線程數(shù)量，以及攔截后調(diào)用的類。線程休眠了秒，線程休眠了秒，但是線程并沒有先執(zhí)行，所以他是在等線程到達(dá)屏障。和可以一個(gè)線程執(zhí)行多次，執(zhí)行多次是無效的。是由外部決定下一步的，是由多個(gè)線程自己決定下一步的。
作用
屏障攔截，構(gòu)造參數(shù)可以傳遞攔截的線程數(shù)量，以及攔截后調(diào)用的Runnable類。每當(dāng)線程調(diào)用await方法的時(shí)候，就告訴CyclicBarrier已經(jīng)到達(dá)了屏障，然后阻塞在那邊，等全部線程都到達(dá)了屏障，線程開始執(zhí)行。
主要方法await：告訴CyclicBarrier已經(jīng)到達(dá)了屏障
示例public class CyclicBarrierDemo {
static CyclicBarrier cyclicBarrier = new CyclicBarrier(2, new Thread3());
static int num = 0;
static class Thread1 implements Runnable {
@Override
public void run() {
try {
num += 1;
Thread.sleep(5000);
cyclicBarrier.await();
System.out.println(Thread.currentThread().getName() + "-" + 1);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
}
}
static class Thread2 implements Runnable {
@Override
public void run() {
try {
num += 1;
Thread.sleep(1000);
cyclicBarrier.await();
System.out.println(Thread.currentThread().getName() + "-" + 2);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
}
}
static class Thread3 implements Runnable {
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + ":num=" + num);
}
}
public static void main(String[] args) {
Thread thread1 = new Thread(new Thread1(), "thread1");
Thread thread2 = new Thread(new Thread2(), "thread2");
thread1.start();
thread2.start();
System.out.println(Thread.currentThread().getName() + ":" + 0);
}
}
運(yùn)行結(jié)果如下：
線程3等到線程1和線程2同時(shí)到達(dá)屏障后，才執(zhí)行，這個(gè)時(shí)候，取到的num就是2了。
線程2休眠了1秒，線程1休眠了5秒，但是線程2并沒有先執(zhí)行，所以他是在等線程1到達(dá)屏障。
CountDownLatch可以一個(gè)線程執(zhí)行多次countDown，CyclicBarrier執(zhí)行多次是無效的。
CountDownLatch是由外部決定下一步的，CyclicBarrier是由多個(gè)線程自己決定下一步的。
比如上課點(diǎn)名，有些老師很隨意，只要人數(shù)滿了，就開始上課，不管有部分學(xué)生變音喊到，都記有人來上課，這個(gè)時(shí)候就是CountDownLatch。有些課程沒有老師，位置坐滿人了，AI播放視頻開始上課，這個(gè)時(shí)候就是CyclicBarrier。
文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址：http://specialneedsforspecialkids.com/yun/75275.html
摘要：作用等待其他線程執(zhí)行完后，在執(zhí)行某個(gè)線程?？梢远鄠€(gè)線程插隊(duì)到線程，線程等多個(gè)線程結(jié)束后才執(zhí)行類似后面的，而可以等待多個(gè)線程執(zhí)行完才執(zhí)行，靈活性比更大。示例執(zhí)行結(jié)果如下雖然線程休眠了秒，但是依然等到線程輸出后，才輸出。 作用 等待其他線程執(zhí)行完后，在執(zhí)行某個(gè)線程。類似之前的join，但是比join更強(qiáng)大。join可以多個(gè)線程插隊(duì)到A線程，A線程等多個(gè)線程結(jié)束后才執(zhí)行（類似后面的Cycli...
摘要：線程安全問題在并發(fā)編程學(xué)習(xí)之基礎(chǔ)概念提到，多線程的劣勢(shì)之一，有個(gè)線程安全問題，現(xiàn)在看看下面的例子。那么，該怎么解決呢，很簡(jiǎn)單，在方法前加個(gè)同步鎖。運(yùn)行結(jié)果如下有兩種情況，是因?yàn)榭凑l先搶占鎖，但是輸出的算法結(jié)果是正確的。 線程安全問題 在java并發(fā)編程學(xué)習(xí)之基礎(chǔ)概念提到，多線程的劣勢(shì)之一，有個(gè)線程安全問題，現(xiàn)在看看下面的例子。 public class NotSafeDemo { ...
摘要：在并發(fā)編程學(xué)習(xí)之顯示鎖里有提過公平鎖和非公平鎖，我們知道他的使用方式，以及非公平鎖的性能較高，在源碼分析的基礎(chǔ)上，我們看看和的區(qū)別在什么地方。而非公平鎖直接嘗試獲取鎖。 在java并發(fā)編程學(xué)習(xí)之顯示鎖Lock里有提過公平鎖和非公平鎖，我們知道他的使用方式，以及非公平鎖的性能較高，在AQS源碼分析的基礎(chǔ)上，我們看看NonfairSync和FairSync的區(qū)別在什么地方。 lock方法 ...
摘要：在并發(fā)編程學(xué)習(xí)之三種線程啟動(dòng)方式中有提過。是否執(zhí)行結(jié)束，包括正常執(zhí)行結(jié)束或異常結(jié)束。獲取返回值，沒有得到返回值前一直阻塞。運(yùn)行結(jié)果如下由于任務(wù)被取消，所以拋出異常。注意的是，此時(shí)線程還在跑，和返回的是。并不能讓任務(wù)真正的結(jié)束。 FutureTask 在java并發(fā)編程學(xué)習(xí)之三種線程啟動(dòng)方式中有提過。主要的方法如下： cancel(boolean mayInterruptIfRunni...
摘要：但是的語義不足以確保遞增操作的原子性，在多線程的情況下，線程不一定是安全的。檢查某個(gè)狀態(tài)標(biāo)記，以判斷是否退出循環(huán)某個(gè)方法這邊和用普通的變量的區(qū)別是，在多線程的情況下，取到后，的值被改變了，判斷會(huì)不正確。 多線程為什么是不安全的 這邊簡(jiǎn)單的講述一下，參考java并發(fā)編程學(xué)習(xí)之synchronize（一） 當(dāng)線程A和線程B同時(shí)進(jìn)入num = num + value; 線程A會(huì)把num的值...
閱讀 3069·2021-11-24 11:14
閱讀 3480·2021-11-22 15:22
閱讀 3200·2021-09-27 13:36
閱讀 712·2021-08-31 14:29
閱讀 1328·2019-08-30 15:55
閱讀 1752·2019-08-29 17:29
閱讀 1143·2019-08-29 16:24
閱讀 2400·2019-08-26 13:48
