java并發(fā)編程學習之CyclicBarrier

lufficc 發(fā)布于2019-08-16 18:32 / 1442人閱讀

摘要：作用屏障攔截，構造參數(shù)可以傳遞攔截的線程數(shù)量，以及攔截后調(diào)用的類。線程休眠了秒，線程休眠了秒，但是線程并沒有先執(zhí)行，所以他是在等線程到達屏障。和可以一個線程執(zhí)行多次，執(zhí)行多次是無效的。是由外部決定下一步的，是由多個線程自己決定下一步的。

作用

屏障攔截，構造參數(shù)可以傳遞攔截的線程數(shù)量，以及攔截后調(diào)用的Runnable類。每當線程調(diào)用await方法的時候，就告訴CyclicBarrier已經(jīng)到達了屏障，然后阻塞在那邊，等全部線程都到達了屏障，線程開始執(zhí)行。

主要方法

await：告訴CyclicBarrier已經(jīng)到達了屏障

示例

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);
    }
}

運行結果如下：

線程3等到線程1和線程2同時到達屏障后，才執(zhí)行，這個時候，取到的num就是2了。
線程2休眠了1秒，線程1休眠了5秒，但是線程2并沒有先執(zhí)行，所以他是在等線程1到達屏障。

CountDownLatch和CyclicBarrier

CountDownLatch可以一個線程執(zhí)行多次countDown，CyclicBarrier執(zhí)行多次是無效的。

CountDownLatch是由外部決定下一步的，CyclicBarrier是由多個線程自己決定下一步的。

比如上課點名，有些老師很隨意，只要人數(shù)滿了，就開始上課，不管有部分學生變音喊到，都記有人來上課，這個時候就是CountDownLatch。有些課程沒有老師，位置坐滿人了，AI播放視頻開始上課，這個時候就是CyclicBarrier。

GPU云服務器云服務器學習之substr() 深度學習之概要 webrtc學習之九 linux學習之centos

文章版權歸作者所有，未經(jīng)允許請勿轉載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉載請注明本文地址：http://m.hztianpu.com/yun/75275.html

java并發(fā)編程學習之CountDownLatch

摘要：作用等待其他線程執(zhí)行完后，在執(zhí)行某個線程。可以多個線程插隊到線程，線程等多個線程結束后才執(zhí)行類似后面的，而可以等待多個線程執(zhí)行完才執(zhí)行，靈活性比更大。示例執(zhí)行結果如下雖然線程休眠了秒，但是依然等到線程輸出后，才輸出。作用等待其他線程執(zhí)行完后，在執(zhí)行某個線程。類似之前的join，但是比join更強大。join可以多個線程插隊到A線程，A線程等多個線程結束后才執(zhí)行（類似后面的Cycli...

antz 2019-08-16 18:32 評論0 收藏0
java并發(fā)編程學習之synchronize（一）

摘要：線程安全問題在并發(fā)編程學習之基礎概念提到，多線程的劣勢之一，有個線程安全問題，現(xiàn)在看看下面的例子。那么，該怎么解決呢，很簡單，在方法前加個同步鎖。運行結果如下有兩種情況，是因為看誰先搶占鎖，但是輸出的算法結果是正確的。線程安全問題在java并發(fā)編程學習之基礎概念提到，多線程的劣勢之一，有個線程安全問題，現(xiàn)在看看下面的例子。 public class NotSafeDemo { ...

Elle 2019-08-16 18:28 評論0 收藏0
java并發(fā)編程學習之再談公平鎖和非公平鎖

摘要：在并發(fā)編程學習之顯示鎖里有提過公平鎖和非公平鎖，我們知道他的使用方式，以及非公平鎖的性能較高，在源碼分析的基礎上，我們看看和的區(qū)別在什么地方。而非公平鎖直接嘗試獲取鎖。在java并發(fā)編程學習之顯示鎖Lock里有提過公平鎖和非公平鎖，我們知道他的使用方式，以及非公平鎖的性能較高，在AQS源碼分析的基礎上，我們看看NonfairSync和FairSync的區(qū)別在什么地方。 lock方法 ...

warkiz 2019-08-19 11:48 評論0 收藏0
java并發(fā)編程學習之FutureTask

摘要：在并發(fā)編程學習之三種線程啟動方式中有提過。是否執(zhí)行結束，包括正常執(zhí)行結束或異常結束。獲取返回值，沒有得到返回值前一直阻塞。運行結果如下由于任務被取消，所以拋出異常。注意的是，此時線程還在跑，和返回的是。并不能讓任務真正的結束。 FutureTask 在java并發(fā)編程學習之三種線程啟動方式中有提過。主要的方法如下： cancel(boolean mayInterruptIfRunni...

BothEyes1993 2019-08-16 18:33 評論0 收藏0
java并發(fā)編程學習之Volatile

摘要：但是的語義不足以確保遞增操作的原子性，在多線程的情況下，線程不一定是安全的。檢查某個狀態(tài)標記，以判斷是否退出循環(huán)某個方法這邊和用普通的變量的區(qū)別是，在多線程的情況下，取到后，的值被改變了，判斷會不正確。多線程為什么是不安全的這邊簡單的講述一下，參考java并發(fā)編程學習之synchronize（一）當線程A和線程B同時進入num = num + value; 線程A會把num的值...

thekingisalwaysluc 2019-08-16 18:28 評論0 收藏0