Java并发编程：线程池使用案例

原创叁歲伎倆 2024-10-18 20:36 59阅读 0赞

线程池在Java并发编程中是一种常用的资源管理方式。它提供了一种重复使用的线程，避免了每次创建新线程的开销。

以下是一个使用Java线程池的经典示例：

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

public class ThreadPoolExample {
    private static final int THREAD_COUNT = 10; // 线程池大小

public static void main(String[] args) {
        // 创建线程池
        ExecutorService executor = Executors.newFixedThreadPool(THREAD_COUNT);

// 提交任务到线程池
        for (int i = 0; i < 100; i++) { // 生成100个任务
            Runnable task = () -> {
                System.out.println("Task " + i + " executed by thread: " + Thread.currentThread().getName());
                try {
                    Thread.sleep(500); // 模拟耗时操作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            };

// 提交任务到线程池
            executor.execute(task);
        }

// 关闭线程池
        executor.shutdown();

// 等待所有任务完成
        while (!executor.isTerminated())) {
            try {
                Thread.sleep(100); // 暂停检查线程池状态
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("All tasks completed by thread pool.");

// 执行关闭资源的操作（例如：关闭文件、数据库连接等）
        // 这个示例没有具体操作，你可以根据你的需求添加这部分代码。
    }
}
```

这个例子中，我们创建了一个固定大小的线程池，然后提交了100个任务到线程池。每个任务都是一个耗时的操作。最后，我们关闭线程池并等待所有任务完成。