亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

如何設置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
洪雅县| 祁门县| 平凉市| 抚松县| 兰西县| 肥乡县| 高要市| 曲周县| 柘荣县| 通海县| 太谷县| 武义县| 南丹县| 香格里拉县| 钦州市| 裕民县| 东港市| 开原市| 井冈山市| 天峻县| 盖州市| 偃师市| 田林县| 绵阳市| 邵东县| 浦城县| 大名县| 凤山市| 理塘县| 淮安市| 屯留县| 平谷区| 祁阳县| 大连市| 定结县| 侯马市| 梅州市| 台北市| 巩义市| 凤山县| 临夏县|