请分析并实现一个Java并发控制的例子，如信号量或CountDownLatch。

原创系统管理员 2025-03-11 16:18 8阅读 0赞

在这个例子中，我们将使用`CountDownLatch`来创建一个简单的并发控制场景。

**1. 定义任务类**

```java
public class Task {
    private int taskNumber;
    private CountDownLatch latch;

public Task(int taskNumber, CountDownLatch latch) {
        this.taskNumber = taskNumber;
        this.latch = latch;
    }

// 任务执行逻辑
    public void executeTask() {
        try {
            System.out.println("Starting task " + taskNumber);
            Thread.sleep(1000); // 模拟耗时任务
            latch.countDown();
            System.out.println("Task " + taskNumber + " completed.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

**2. 创建CountDownLatch并初始化**

```java
public class Main {
    public static void main(String[] args) throws InterruptedException {
        int totalTasks = 5; // 设置总任务数
        CountDownLatch latch = new CountDownLatch(totalTasks); // 初始化计数器

// 创建任务并添加到线程池
        ExecutorService executorService = Executors.newFixedThreadPool(totalTasks);
        List<Task> tasks = new ArrayList<>();
        for (int i = 1; i <= totalTasks; i++) {
            Task task = new Task(i, latch);
            tasks.add(task);
        }
        executorService.invokeAll(tasks);

// 等待所有任务完成
        latch.await();

System.out.println("All tasks completed.");
    }
}
```

这个例子中，我们创建了一个`CountDownLatch`来控制并发任务。每个任务执行完成后都会调用`latch.countDown()`来减少计数器的值。主线程会等待所有计数器为0时才会继续执行后续逻辑。