Java Executor执行器如何实现任务队列

在Java中，Executor接口和它的实现类（如ThreadPoolExecutor）提供了一种将任务提交给线程池执行的方式。任务队列是线程池的一个重要组成部分，它用于保存等待执行的任务。

以下是如何使用ThreadPoolExecutor实现任务队列的步骤：

1. 导入必要的包：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

2. 创建一个任务队列：

BlockingQueue<Runnable> taskQueue = new LinkedBlockingQueue<>(10);

这里我们使用了LinkedBlockingQueue作为任务队列，它可以容纳10个任务。你可以根据需要选择其他类型的队列。

3. 创建一个线程池：

int corePoolSize = 5; // 核心线程数
int maximumPoolSize = 10; // 最大线程数
long keepAliveTime = 60L; // 空闲线程存活时间

ExecutorService executorService = new ThreadPoolExecutor(
        corePoolSize,
        maximumPoolSize,
        keepAliveTime,
        TimeUnit.SECONDS,
        taskQueue
);

这里我们创建了一个核心线程数为5，最大线程数为10的线程池。空闲线程在60秒后会被终止。任务队列是我们之前创建的taskQueue。

4. 向线程池提交任务：

for (int i = 0; i < 20; i++) {
    Runnable task = new MyTask(i);
    executorService.submit(task);
}

这里我们提交了20个任务到线程池。线程池会根据当前任务数量和线程池大小来决定如何处理这些任务。

5. 关闭线程池：

executorService.shutdown();

在所有任务完成后，调用shutdown()方法关闭线程池。这将阻止新任务提交到线程池，并允许现有任务完成执行。

这是一个简单的示例，展示了如何使用ThreadPoolExecutor实现任务队列。你可以根据需要调整线程池参数和任务队列类型。