关闭后如何重用ThreadPoolExecutor

Question

在我的应用程序中，我使用了一个自定义的 ThreadPoolExecutor，它通过扩展 ThreadPoolExecutor 类来实现 Executor 的暂停和恢复。同样，我希望在执行 ExecutorService 的关闭方法之后实现重新启动功能。我首先尝试创建ThreadPoolExecutor 的新实例，但失败了。我找到了 this question 并尝试了 ExecutorCompletionService ，结果同样失败，没有按预期执行。

当我第一次单击 UI 中的开始按钮时，它执行得很好，并且在完成该过程后，当我再次开始时，它不会给我预期的结果。相反，会给我与第一次运行相同的结果。我可以完成这项任务的最合适的方法是什么？ 在此先感谢:)

每次点击按钮都会执行以下几行。

    private static int jobs = 10;
    ExecutorService executor = new PausableThreadPoolExecutor(num_threads, num_threads, 5000, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(jobs));
    for (int i = 0; i < jobs; i++) {
        Runnable worker = new TaskToDo(jobs);
        executor.submit(worker);
    }

    executor.shutdown();
    while (!executor.isTerminated()) {}
    System.out.println("Finished all threads");

This 是我用来实现暂停/恢复的来源。

Answer 1

也许一个 ScheduledThreadPoolExecutor 你可以重启它ScheduledThreadPoolExecutor 使用此方法可以返回 ScheduledFuture ScheduledFuture 或 Future Future 来保存对任务的引用

ScheduledFuture now = null;
ScheduledThreadPoolExecutor scheduler = new ScheduledThreadPoolExecutor(1);
Runnable runner = new Runnable(){
                public void run()
                {
                    rollthedice(); //your method or runnable of choice
                }
            };

启动和重新启动类似“theres other methods too”之类的东西

now = scheduler.scheduleAtFixedRate(runner, 0, 250, TimeUnit.MILLISECONDS);

取消或停止

now.cancel(true);
now = null;