我有這種生產(chǎn)者消費(fèi)者的情況，我正在使用 arrayblockingqueue。如果消費(fèi)者線程遇到異常，如何停止生產(chǎn)者線程。我需要生產(chǎn)者停止等待隊(duì)列為空。我引發(fā)了強(qiáng)制運(yùn)行時異常。但程序并沒有退出。生產(chǎn)者一直等待隊(duì)列為空。有人可以幫忙嗎public class ServiceClass implements Runnable{    private final static BlockingQueue<Integer> processQueue = new ArrayBlockingQueue<>(10);    private static final int CONSUMER_COUNT = 1;    private boolean isConsumerInterrupted = false;    private boolean isConsumer = false;    private static boolean producerIsDone = false;    public ServiceClass(boolean consumer,boolean isConsumerInterrupted) {        this.isConsumer = consumer;        this.isConsumerInterrupted = isConsumerInterrupted;    }    public static void main(String[] args) {        long startTime = System.nanoTime();        ExecutorService producerPool = Executors.newFixedThreadPool(1);        producerPool.submit(new ServiceClass(false,false)); // run method is                                                         // called           // create a pool of consumer threads to parse the lines read        ExecutorService consumerPool = Executors.newFixedThreadPool(CONSUMER_COUNT);        for (int i = 0; i < CONSUMER_COUNT; i++) {            consumerPool.submit(new ServiceClass(true,false)); // run method is                                                            // called        }        producerPool.shutdown();        consumerPool.shutdown();        while (!producerPool.isTerminated() && !consumerPool.isTerminated()) {        }        long endTime = System.nanoTime();        long elapsedTimeInMillis = TimeUnit.MILLISECONDS.convert((endTime - startTime), TimeUnit.NANOSECONDS);        System.out.println("Total elapsed time: " + elapsedTimeInMillis + " ms");    }    @Override    public void run() {        if (isConsumer) {            consume();        } else {            readFile(); //produce data by reading a file        }    }