ScheduledExecutorService一个线程很多任务

Question

我是新手,ExecutorService并想知道为什么下面的代码正确打印"10 15",即使我只创建了一个线程来处理超时？为什么我可以多次调用调度而不在单个线程执行器上取消先前的任务？

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;


public class TestExecutorService implements Runnable {
    public static ScheduledExecutorService SERVICE = Executors.newSingleThreadScheduledExecutor();
    private int delay;


    public TestExecutorService(int delay) {
        this.delay = delay;
    }

    public void run () {
        System.out.println(delay);
    }

    public static void main (String[] args) {
        SERVICE.schedule(new TestExecutorService(10), 10, TimeUnit.SECONDS);
        SERVICE.schedule(new TestExecutorService(15), 15, TimeUnit.SECONDS);

        SERVICE.shutdown();
    }
}

Answer 1

来自Javadocs:

保证任务按顺序执行,并且在任何给定时间不会有多个任务处于活动状态.

"处理超时"和"任务执行"之间的区别是答案的关键.您假设"单线程"意味着"一次只处理一个超时",但它实际上意味着"一次只执行一个任务".所有超时都会同时处理,但如果在任务停止执行之前达到一个超时,则必须等待另一个超时才能执行.

Answer 2

在这种情况下阅读Javadoc非常有用.它确实解释了虽然执行程序将使用单个线程创建,但它将以无界队列运行.这意味着您可以向执行程序提交多个任务,它们将排队等候一个接一个地运行,直到队列的最大边界(在这种情况下是无穷大)或直到JVM资源耗尽为止.

创建一个Executor,它使用一个在无界队列中运行的工作线程.(但请注意,如果此单个线程由于在关闭之前执行期间的故障而终止,则在需要执行后续任务时将使用新的线程.)保证任务按顺序执行,并且不会有多个任务处于活动状态在任何给定的时间.与其他等效的newFixedThreadPool(1)不同,保证返回的执行程序不可重新配置以使用其他线程.

在您的示例中,您的两个任务排队,并依次顺序运行,这就是您获得(预期)输出的原因.