ArrayBlockingQueue NoSuchElementException

Question

仅供学习，我编写了以下代码用于自定义线程池引用和编辑此处显示的代码。如代码所示，我将 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();            }此代码有时运行良好，有时会出错。

Answer 1

在“while”检查和实际删除之间，队列可能会被另一个线程修改，这可能会导致您提到的错误。这就是所谓的“竞争条件”。

因此，为了解决这个问题，您需要一种方法来阻止其他线程对队列的访问，或者通过“锁定”，使用带有共享锁定对象的“同步”块。或者简单地通过“轮询”而不是删除。