Java并发工具类：ThreadPoolExecutor示例

原创 ╰+攻爆jí腚メ 2024-12-03 18:33 17阅读 0赞

`ThreadPoolExecutor`是Java中一个常用的线程池工具，它可以帮助我们更好地管理和控制多任务执行。下面是一个简单的使用`ThreadPoolExecutor`的例子：

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

public class ThreadPoolExecutorExample {
    public static void main(String[] args) {
        // 创建线程池，核心线程数为2，最大线程数为5
        ExecutorService executor = Executors.newThreadPool(5, 2);

// 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            final int index = i;
            executor.submit(() -> {
                System.out.println("Task " + index + " is running by thread: " + Thread.currentThread().getName());
                try {
                    // 模拟任务执行时间
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + index + " completed.");
            });
        }

// 关闭线程池，所有提交的任务将被取消（如果任务还没有完成）
        executor.shutdown();

// 等待所有任务完成或线程池关闭
        while (!executor.isTerminated()) {
            try {
                Thread.sleep(100);  // 每秒检查一次，避免阻塞主线程
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

// 线程池已关闭，所有提交的任务已完成
        System.out.println("All tasks completed. ThreadPoolExecutor is shutdown.");
    }
}
```

在这个例子中，我们创建了一个包含5个线程的线程池。然后我们提交了10个任务到线程池。每个任务都是在一个新的线程上执行的。

最后，我们调用`executor.shutdown()`关闭线程池，等待所有任务完成或线程池关闭。