中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

如何設置Java Barrier的閾值

小樊
81
2024-08-16 08:23:37
欄目: 編程語言

在Java中,可以使用CyclicBarrier類來設置Barrier的閾值。CyclicBarrier類有一個構造方法,可以指定需要等待的線程數量作為參數,這個數量就是Barrier的閾值。當等待的線程數量達到指定的閾值時,所有線程將被釋放并繼續執行。

下面是一個示例代碼,演示如何設置CyclicBarrier的閾值:

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class BarrierExample {
    public static void main(String[] args) {
        int numberOfThreads = 3; // 設置Barrier的閾值為3

        CyclicBarrier barrier = new CyclicBarrier(numberOfThreads, new Runnable() {
            @Override
            public void run() {
                System.out.println("All threads have reached the barrier");
            }
        });

        for (int i = 0; i < numberOfThreads; i++) {
            Thread thread = new Thread(new Worker(barrier));
            thread.start();
        }
    }

    static class Worker implements Runnable {
        private CyclicBarrier barrier;

        public Worker(CyclicBarrier barrier) {
            this.barrier = barrier;
        }

        @Override
        public void run() {
            try {
                System.out.println(Thread.currentThread().getName() + " is waiting at the barrier");
                barrier.await(); // 等待所有線程到達Barrier
                System.out.println(Thread.currentThread().getName() + " has passed the barrier");
            } catch (InterruptedException | BrokenBarrierException e) {
                e.printStackTrace();
            }
        }
    }
}

在上面的示例中,我們創建了一個CyclicBarrier對象,并指定了閾值為3。然后創建了3個Worker線程,每個線程在執行過程中都會調用CyclicBarrier的await()方法來等待其他線程。當所有線程都到達Barrier時,會執行指定的Runnable任務,并繼續執行各個線程。

0
北宁市| 武宣县| 仲巴县| 临桂县| 白水县| 罗田县| 江川县| 南投市| 共和县| 昌平区| 罗甸县| 芒康县| 宜春市| 陕西省| 惠州市| 苗栗市| 浦城县| 九寨沟县| 新宾| 云南省| 万全县| 永新县| 沁阳市| 乳山市| 汝阳县| 德兴市| 潜江市| 德惠市| 库伦旗| 大荔县| 临桂县| 瑞安市| 和硕县| 平罗县| 宁乡县| 黄浦区| 汉阴县| 固镇县| 大邑县| 福鼎市| 五指山市|