Rumah > Java > javaTutorial > Bagaimana untuk menentukan pembilang Java CountDownLatch dan penghalang kitaran CyclicBarrier

Bagaimana untuk menentukan pembilang Java CountDownLatch dan penghalang kitaran CyclicBarrier

WBOY
Lepaskan: 2023-05-21 18:25:14
ke hadapan
763 orang telah melayarinya

Definisi

CountDownLatch: Alat bantuan penyegerakan yang membenarkan satu atau lebih urutan menunggu sehingga satu set operasi yang dijalankan dalam urutan lain selesai.

CyclicBarrier: Bantuan penyegerakan yang membolehkan satu set utas kepada semua menunggu antara satu sama lain untuk mencapai titik halangan yang sama.

Di atas ialah takrifan rasmi Oracle. Ringkasnya

CountDownLatch: Counter yang membenarkan satu atau lebih utas menunggu sehingga satu set operasi yang dilakukan dalam urutan lain selesai.

Penghalang Kitaran: Penghalang Kitaran, yang membenarkan sekumpulan utas menunggu antara satu sama lain untuk mencapai titik halangan yang sama.

Perbezaan

  • CountDownLatch ialah ahli AQS (AbstractQueuedSynchronizer), tetapi CyclicBarrier tidak.

  • Dalam senario penggunaan CountDownLatch, terdapat dua jenis utas, satu ialah utas menunggu yang memanggil kaedah await() dan satu lagi ialah utas operasi yang memanggil countDownl () kaedah. Dalam konteks CyclicBarrier, semua utas ialah utas yang menunggu antara satu sama lain dan daripada jenis yang sama.

  • CountDownLatch ialah kiraan turun, ia tidak boleh ditetapkan semula selepas penurunan, CyclicBarrier ialah kiraan naik, ia ditetapkan semula secara automatik selepas kenaikan

Contoh CountDownLatch

Buat dua kumpulan benang, satu kumpulan menunggu kumpulan lain selesai melaksanakan sebelum meneruskan

CountDownLatch countDownLatch = new CountDownLatch(5);
ExecutorService executorService = Executors.newCachedThreadPool();
for (int i = 0; i < 5; i++) {
    executorService.execute(() -> {
        countDownLatch.countDown();
        System.out.println("run..");
    });
}
for (int i = 0; i < 3; i++) {  //我们要等上面执行完成才继续
    executorService.execute(() -> {
        try {
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("await..");
    });
}
executorService.shutdown();
Salin selepas log masuk

Cetak:

lari..
lari..
lari ..
lari..
lari..
tunggu..
tunggu..
tunggu..

Tunggu untuk utas pengumpulan selesai melaksanakan, dan kemudian utas utama Keluarkan hasil terkumpul

public class ThreadUnsafeExample {
    private int cnt = 0;
    public void add() {
        cnt++;
    }
    public int get() {
        return cnt;
    }
    public static void main(String[] args) throws InterruptedException {
        final int threadSize = 1000;
        ThreadUnsafeExample example = new ThreadUnsafeExample();
        final CountDownLatch countDownLatch = new CountDownLatch(threadSize);
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < threadSize; i++) {
            executorService.execute(() -> {
                example.add();
                countDownLatch.countDown();
            });
        }
        countDownLatch.await();
        executorService.shutdown();
        System.out.println(example.get());
    }
}
Salin selepas log masuk

Cetak:

997

3 Simulasi konkurensi

ExecutorService executorService = Executors.newCachedThreadPool();
        CountDownLatch countDownLatch = new CountDownLatch(1);
        for (int i = 0; i < 5; i++) {
            executorService.submit( () -> {
                try {
                    countDownLatch.await();
                    System.out.println("【" + Thread.currentThread().getName() + "】开始执行……");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }
        Thread.sleep(2000);
        countDownLatch.countDown();//开始并发
        executorService.shutdown();
Salin selepas log masuk

Cetak:

【pool-2-thread-2】Mulakan pelaksanaan……
【pool-2-thread-5】Mulakan pelaksanaan…&hellip>;<🎜 【pool-2-thread-3】Mulakan pelaksanaan&hellip ;…
[pool-2-thread-1] memulakan pelaksanaan……
[pool-2-thread-4] memulakan pelaksanaan……

Contoh CyclicBarrier

Semua utas menunggu antara satu sama lain sehingga langkah tertentu selesai sebelum meneruskan

        final int totalThread = 3;
        CyclicBarrier cyclicBarrier = new CyclicBarrier(3);
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < totalThread; i++) {
            executorService.execute(() -> {
                System.out.println("before..");
                try {
                    cyclicBarrier.await();
                } catch (InterruptedException | BrokenBarrierException e) {
                    e.printStackTrace();
                }
                System.out.println("after..");
            });
        }
        executorService.shutdown();
Salin selepas log masuk
Cetak:

sebelum..

sebelum..
sebelum ..
selepas..
selepas..
selepas..

Atas ialah kandungan terperinci Bagaimana untuk menentukan pembilang Java CountDownLatch dan penghalang kitaran CyclicBarrier. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

Label berkaitan:
sumber:yisu.com
Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan