僅供學習，我編寫了以下代碼用于自定義線程池引用和編輯此處顯示的代碼。如代碼所示，我將 ArrayBlockingQueue 用于任務隊列。代碼：import java.util.ArrayList;import java.util.List;import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.BlockingQueue;import java.util.concurrent.TimeUnit;public class ThreadPoolService {    private final BlockingQueue<Runnable> taskQueue;    private final int corePoolSize;    private ThreadPoolService(int corePoolSize) {        this.corePoolSize = corePoolSize;        this.taskQueue = new ArrayBlockingQueue<>(corePoolSize);        ThreadPool[] threadPool = new ThreadPool[corePoolSize];        for (int i = 0; i < corePoolSize; i++) {            threadPool[i] = new ThreadPool();            threadPool[i].start();        }    }    public static ThreadPoolService newFixedThreadPool(int size) {        return new ThreadPoolService(size);    }    public void execute(Runnable task) {        try {            taskQueue.offer(task, 10, TimeUnit.SECONDS);        } catch (InterruptedException e) {            e.printStackTrace();        }    }    private class ThreadPool extends Thread {        Runnable task;        @Override        public void run() {            while (true) {                try {                    while (!taskQueue.isEmpty()) {                        task = taskQueue.remove();                        task.run();                    }                } catch (RuntimeException ex) {                    ex.printStackTrace();                }            }        }    }    public static void main(String[] args) {        ThreadPoolService pool = ThreadPoolService.newFixedThreadPool(10);        Runnable task1 = () -> {            System.out.println(" Wait for sometime: -> " + Thread.currentThread().getName());            try {                TimeUnit.SECONDS.sleep(2);            } catch (InterruptedException e) {                e.printStackTrace();            }此代碼有時運行良好，有時會出錯。