将任务移动到单独的线程，避免任务运行时重复

Question

我们在遗留代码和当前代码之间有一个粘合组件。本质上，整个遗留应用程序是单线程的，并且存在可怕的问题，单个指令的用户界面刷新可能会发生5到8次。

我想在第一次更新请求发生2秒后发布一条异步消息。

让我们不要纠结于为什么，这不是我真正想要做的，但我必须了解如何至少做到这一点，这样我才能实施真正的解决方案。

Runnable task = () -> {
    try {
        TimeUnit.SECONDS.sleep(2);
        messageBus.publishAsynch(new LegacyUiUpdateEvent());
    } catch (InterruptedException e) {
        // TODO Log something
        Thread.currentThread().interrupt();
    }
};

@Override
public void update(Observable arg0, Object arg1) {
    ExecutorService executor = Executors.newSingleThreadExecutor();
    if (futureTask == null || futureTask.isDone()) {
        futureTask = executor.submit(task);
        try {
            executor.awaitTermination(10, TimeUnit.SECONDS);
            executor.shutdownNow();
        } catch (InterruptedException e) {
            // TODO Log something
            Thread.currentThread().interrupt();
        }
    }
}

理论是：如果未来的任务不存在，我们会创建它，一旦它存在，如果它没有完成（因为这是错误的遗留更新4/x，其中x∈ [5,12]睡眠仍然有效）然后我们完全跳过，不创建新的执行器。

问题是，据我所知，执行者。提交（任务）实际上并不会在新的进程中发生。就像我说的，旧版应用程序是单线程的，在我将睡眠时间增加到15秒后，很明显它正在将当前的整个线程发送到睡眠状态。

我如何将我的任务放在一个全新的线程上（使用并发库）并避免多次执行该任务，即使update方法被调用的次数太多（这完全超出了我的控制）。我认为是未来。isDone（）这玩意儿行得通，但不是100%

Answer 1

执行者。submit（）会在新线程中启动任务，但就在执行器之后。等待终止（10，时间单位秒） 正在当前线程中等待任务完成。不需要在当前线程中等待，但需要有一种方法来确定任务是否已经在运行。

混乱的部分是每次都创建ExecutorService——没有必要每次都重新创建它。它可以是类的实例变量，可以重复使用。理想情况下，它将通过构造函数注入，以便创建它的类可以在确实需要时关闭它。

 private final ExecutorService executor = Executors.newSingleThreadExecutor();  // or injected through constructor
 private Future<?> futureTask;

@Override
public void update(Observable arg0, Object arg1) {
    if (futureTask == null || futureTask.isDone()) {
        futureTask = executor.submit(task);
    }
}

Answer 2

如果你是在Java8或更高这是一个更好的事情要做

CompletableFuture.runAsync(task);

因为这将在Fork-join线程池上执行，该线程池由JVM管理，您不会因为创建或关闭它而担心自己。当然，这将异步运行，符合您的需求。