主页 / 问题 / 947037
Accepted
Леонид Дубравский
Asked:2020-02-20 16:24:15 +0000 UTC2020-02-20 16:24:15 +0000 UTC

如何从 ExecutorService 中删除队列但等​​待正在运行的线程执行？

  • 772

有：

 ExecutorService executor = Executors.newFixedThreadPool(threadPoolSize);

需要正确停止执行器，以免中断正在运行的线程并删除所有在队列中等待的线程。

shutdownNow()- 降低执行者，所以这是不可能的。
shutdown()- 等到整个队列以及预期的队列结束，并且有数以万计的队列。

试过：

BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(threadPoolSize);
executor = new ThreadPoolExecutor(threadPoolSize, threadPoolSize, 0L, TimeUnit.MILLISECONDS, queue);

然后：

executor.shutdown();
 queue.clear();

但是这里出了点问题，因为队列没有被刷新。

java

1 个回答

  1. Best Answer

    这是一个清除队列的工作示例。

    public class App {
    public static void main(String[] args) {

        ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(1000);
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                1,
                1,
                0L,
                TimeUnit.MILLISECONDS,
                queue);

        for (int i = 0; i < 100; i++) {
            int j = i;
            executor.submit(() ->{
                try {
                    Thread.sleep(100);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("i = " + j);
            });
        }

        executor.shutdown();
        queue.clear();
    }
}

    只运行一项任务。

    • 0

相关问题