Java ExecutorService如何实现任务队列

在Java中，ExecutorService是一个接口，它提供了一种将任务提交给线程池执行的方式。ExecutorService内部使用一个任务队列来存储待处理的任务。当有新任务提交给ExecutorService时，它会将任务添加到任务队列中。线程池中的工作线程会从任务队列中获取任务并执行。

要实现一个具有任务队列的ExecutorService，你可以使用Java提供的线程池实现，例如ThreadPoolExecutor。以下是一个简单的示例，展示了如何使用ThreadPoolExecutor创建一个具有任务队列的ExecutorService：

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

public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个具有固定线程数量的线程池
        int numberOfThreads = 5;
        ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads);

        // 提交10个任务给线程池
        for (int i = 0; i < 10; i++) {
            Runnable task = new Task(i);
            executorService.submit(task);
        }

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

        // 等待所有任务执行完毕
        try {
            if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
                executorService.shutdownNow();
            }
        } catch (InterruptedException e) {
            executorService.shutdownNow();
        }
    }

    static class Task implements Runnable {
        private int taskId;

        public Task(int taskId) {
            this.taskId = taskId;
        }

        @Override
        public void run() {
            System.out.println("Task " + taskId + " is running on thread " + Thread.currentThread().getName());
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Task " + taskId + " is completed");
        }
    }
}

在这个示例中，我们创建了一个具有5个线程的线程池。然后，我们提交了10个任务给线程池。线程池会将这些任务添加到任务队列中，并使用线程池中的工作线程来执行它们。最后，我们关闭线程池并等待所有任务执行完毕。