Java并发编程：CountDownLatch案例解析

原创墨蓝 2024-09-20 14:00 79阅读 0赞

CountDownLatch是Java中的一种同步工具，主要用来协调多个线程的执行。当一个或多个线程完成其任务后，会调用`countDown()`方法将计数器减1，这时其他等待的线程就可以继续执行了。

下面是一个简单的CountDownLatch案例解析：

```java
import java.util.concurrent.CountDownLatch;

public class CounterExample {
    private CountDownLatch countDownLatch;
    private int totalTasks = 5; // 五个人完成任务

public CounterExample() {
        countDownLatch = new CountDownLatch(totalTasks);
    }

// 每个线程的任务实现
    public void workerThread(int index) throws InterruptedException {
        System.out.println("Worker thread " + index + " starts...");
        
        // 调用countDown()方法，将计数器减1
        countDownLatch.countDown();

System.out.println("Worker thread " + index + " finishes.");
    }

public static void main(String[] args) throws InterruptedException {
        CounterExample counter = new CounterExample();
        
        // 创建五个线程，每个线程执行workerThread方法
        Thread thread1 = new Thread(counter::workerThread, 0));
        Thread thread2 = new Thread(counter::workerThread, 1));
        Thread thread3 = new Thread(counter::workerThread, 2));
        Thread thread4 = new Thread(counter::workerThread, 3));

// 启动线程
        thread1.start();
        thread2.start();
        thread3.start();
        thread4.start();

// 等待所有线程执行完毕
        countDownLatch.await(); // 注意这里的countDownLatch必须是共享的，否则await会一直阻塞

System.out.println("All threads have finished.");
    }
}
```

在这个例子中，我们创建了一个CountDownLatch实例，并将它作为共享变量传递给所有线程。每个线程的任务就是调用`countDown()`方法减小计数器。

主线程通过调用`await()`方法等待所有线程执行完毕。当计数器为0时，其他等待的线程就可以继续执行了。