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

原创青旅半醒 2024-12-03 14:06 5阅读 0赞

在Java并发编程中，线程池是一种常用的资源管理模式，它可以重用已经创建的线程，避免频繁创建和销毁线程带来的性能损失。

以下是一个使用Apache Commons Lang和ThreadPoolExecutor实现线程池的简单案例：

```java
import org.apache.commons.lang3.concurrent.ConcurrentUtils;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

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

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

// 将一些任务放入线程池
        ConcurrentUtils.runParallel(() -> {
            System.out.println("Task started by thread " + Thread.currentThread().getName()); // 输出当前线程名

try {
                Thread.sleep(500); // 模拟耗时操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

System.out.println("Task completed by thread " + Thread.currentThread().getName())); // 输出任务完成信息
        }, THREAD_COUNT)); // 并行执行任务

// 关闭线程池，确保所有任务完成后关闭
        executorService.shutdown();
        while (!executorService.isTerminated())) {
            try {
                Thread.sleep(100); // 等待服务状态更新
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
```

在这个例子中，我们创建了一个固定大小的线程池，并将10个任务放入线程池并行执行。最后，我们关闭线程池，确保所有任务完成后关闭。