并发编程：Java的线程池和CountDownLatch示例

原创柔情只为你懂 2024-12-06 17:00 26阅读 0赞

在Java中，多线程可以通过多种方式实现，其中线程池和CountDownLatch是常用的工具。

1. 线程池：
线程池是一种重复利用已有线程实例来执行常用任务的管理机制。Java的`ExecutorService`和`ThreadPoolExecutor`就是用来创建线程池的类。

下面是一个简单的线程池示例：

```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池，每个任务都是独立执行的
        for (int i = 0; i < 10; i++) {
            Runnable task = new Task("Task " + i);
            executor.execute(task);
        }

// 关闭线程池，释放资源
        executor.shutdown();

// 确保所有任务都已完成
        while (!executor.isTerminated()) {
            System.out.println("Task is still running...");
            try {
                Thread.sleep(1000); // 暂停一秒，观察是否还有任务正在运行
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 所有任务都已完成
        System.out.println("All tasks completed!");

// 关闭线程池
        executor.shutdownNow();
    }
}

class Task implements Runnable {
    private String name;

public Task(String name) {
        this.name = name;
    }

@Override
    public void run() {
        System.out.println("Task " + name + " started...");

try {
            Thread.sleep(2000); // 暂停两秒，模拟任务执行过程
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("Task " + name + " completed!");

// 在线程结束后执行一些清理工作（这里仅示例）
        Thread.currentThread().getName();  // 获取当前线程的名称
        System.out.println("Cleanup for Task " + name + " performed...");

}
}
```

这个例子展示了如何创建一个固定大小的线程池，以及如何使用`CountDownLatch`来协调多个任务的执行顺序。