并发困惑：Java线程池管理示例

原创曾经终败给现在 2024-12-09 20:09 11阅读 0赞

在Java编程中，线程池是一种常用的并发资源管理方式。它通过预先创建一组可复用的线程，当有新的任务需要执行时，会从线程池中取出线程来处理新任务，从而提高系统的并发处理能力。

以下是一个简单的Java线程池管理示例：

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

public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        int threadCount = 5; // 根据实际需求设置
        ExecutorService executor = Executors.newFixedThreadPool(threadCount);

// 提交任务到线程池执行
        for (int i = 0; i < 10; i++) {
            final int taskIndex = i;
            executor.submit(() -> {
                System.out.println("Task " + taskIndex + " is executing by thread " + Thread.currentThread().getName());
                try {
                    // 这里可以是你的任务处理逻辑
                    TimeUnit.SECONDS.sleep(2);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }

// 关闭线程池，不再接受新的提交任务
        executor.shutdown();

// 等待所有任务完成（如果有必要）
        while (!executor.isTerminated()) {
            try {
                // 如果等待时间过长，可以设置超时时间
                TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 打印线程池状态信息
        System.out.println("Executor status: " + executor.isTerminated() + ", pool size: " + executor.getPoolSize());

// 如果需要释放资源（比如关闭数据库连接等）
        // 在这里添加你的清理逻辑代码
    }
}
```

这个示例创建了一个固定大小的线程池，并提交了10个任务到线程池执行。最后，关闭了线程池以释放资源。