溫馨提示×

java怎么等待多個線程結束

小億
137
2023-11-06 20:43:12
欄目: 編程語言

Java中可以使用CountDownLatch類來等待多個線程結束。

CountDownLatch類是Java提供的一個同步輔助類,它可以使一個或多個線程等待其他線程完成操作后再繼續執行。

具體步驟如下:

  1. 創建一個CountDownLatch對象,并將計數器初始化為線程數。
  2. 在每個線程的操作完成后,調用CountDownLatch對象的countDown()方法,將計數器減1。
  3. 在主線程中,調用CountDownLatch對象的await()方法,等待所有線程完成操作,當計數器為0時,主線程恢復執行。

示例代碼如下:

import java.util.concurrent.CountDownLatch;

public class WaitMultipleThreads {
    public static void main(String[] args) {
        int threadCount = 5;
        CountDownLatch latch = new CountDownLatch(threadCount);

        for (int i = 0; i < threadCount; i++) {
            Thread thread = new Thread(new MyRunnable(latch));
            thread.start();
        }

        try {
            latch.await(); // 等待所有線程執行完成
            System.out.println("All threads have finished.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    static class MyRunnable implements Runnable {
        private final CountDownLatch latch;

        public MyRunnable(CountDownLatch latch) {
            this.latch = latch;
        }

        @Override
        public void run() {
            // 線程操作邏輯
            // ...

            latch.countDown(); // 線程執行完畢,計數器減1
        }
    }
}

在這個示例中,首先創建了一個CountDownLatch對象,并將計數器初始化為5。然后通過一個循環創建了5個線程,并將CountDownLatch對象作為參數傳遞給每個線程的構造函數。

在每個線程的run()方法中,執行線程操作的邏輯,并在最后調用latch.countDown()方法將計數器減1。

最后,在主線程中調用latch.await()方法,等待所有線程執行完成。當計數器為0時,主線程恢復執行,輸出"All threads have finished"。

0
亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女