JAVA schedule pool 理解

java schedule implement

如下例：

public static void main(String[] args) {
    ScheduledThreadPoolExecutor pool = new ScheduledThreadPoolExecutor(1);
    //task1
    pool.schedule(()->{
        System.out.println(1);
    },10,TimeUnit.SECONDS);
    //task2
    pool.schedule(()->{
        System.out.println(1);
    },5,TimeUnit.SECONDS);
    //task3
    pool.schedule(()->{
        System.out.println(1);
    },2,TimeUnit.SECONDS);
}

要点
1.task1,task2,task3被加入到java.util.concurrent.ScheduledThreadPoolExecutor.DelayedWorkQueue中，经过了时间排序，最先执行的放到最上面。
2.worker线程使用take() or poll() 从DelayedWorkQueue中取出第一个元素，如果第一个元素还没有到时间，就等待执行。


问题：
1.如果放入新task过程中时，同时worker从DelayedWorkQueue取出任务，怎么同步？
caller放入新的task时，会使用ReentrantLock加锁，此时worker线程就会等待直到任务添加完毕并释放锁。
2.如果worker从DelayedWorkQueue取出任务过程中，同时新的task放入到DelayedWorkQueue中，怎么同步？
如果取出任务并且在等待中（worker线程），那么在放入新任务时（caller线程），caller唤醒worker的等待，然后caller插入新任务,worker重新获取最新任务。