Java并发工具类：线程池管理实例

原创梦里梦外; 2024-11-15 19:03 2阅读 0赞

在Java编程中，线程池是一个重要的并发工具。它通过维护一组可复用的线程来提高程序对大量并发请求的处理能力。

以下是一个简单的线程池管理实例，使用了`ThreadPoolExecutor`：

```java
import java.util.concurrent.*;

public class ThreadPoolExample {
    private static final int THREAD_COUNT = 10; // 线程数量

public static void main(String[] args) {
        // 创建线程池
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                THREAD_COUNT, // 核心线程数
                Integer.MAX_VALUE, // 非核心线程最大数量，允许无限增长
                0L, // 空闲线程超时时间，无限等待
                Executors.defaultThreadFactory(), // 线程工厂，生成线程
                new ThreadPoolExecutor.RunnableAdapter() // 运行任务的适配器，将任务包装为Runnable对象
        );

// 提交任务到线程池
        for (int i = 0; i < 100; i++) { // 模拟100个任务
            executor.execute(() -> {
                // 这里是执行任务的代码，比如处理数据或者进行网络请求等。
                System.out.println("Task " + i + " executed.");
            });
        }

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

这个例子中，我们创建了一个包含10个核心线程的线程池。然后提交了100个任务到线程池进行执行。

最后，当所有任务完成后，我们关闭线程池以释放资源。