线程池阻塞队列 代码

当我们使用线程池时，通常会使用阻塞队列来管理任务的排队和执行。下面是一个简单的示例代码，展示了如何使用阻塞队列来实现线程池。

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;

public class ThreadPoolExample {
    public static void main(String[] args) {
        // 创建一个阻塞队列
        BlockingQueue<Runnable> blockingQueue = new LinkedBlockingQueue<>(10);

        // 创建一个线程池，指定线程数量为5
        ExecutorService executor = Executors.newFixedThreadPool(5);

        // 向线程池提交任务
        for (int i = 0; i < 10; i++) {
            executor.submit(new Task(i));
        }

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

    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.");
            try {
                // 模拟任务执行时间
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Task " + taskId + " is completed.");
        }
    }
}

在上述代码中，我们首先创建了一个大小为10的`LinkedBlockingQueue`作为阻塞队列，用于存储待执行的任务。然后，我们使用`Executors.newFixedThreadPool()`方法创建一个固定大小为5的线程池。

接下来，我们使用`executor.submit()`方法向线程池提交任务。每个任务都是一个`Task`对象，该对象实现了`Runnable`接口。在`run()`方法中，我们定义了任务的具体逻辑。

最后，我们调用`executor.shutdown()`方法来关闭线程池。

以上就是一个简单的使用阻塞队列实现线程池的示例代码。希望能对你有所帮助！如果有更多的问题，请随时提问。