io.netty.util.concurrent.AbstractScheduledEventExecutor

Question

• 这节课中讲到了`io.netty.util.concurrent.AbstractScheduledEventExecutor`的`schedule
  ()`方法

Queue<ScheduledFutureTask<?>> scheduledTaskQueue;

Queue<ScheduledFutureTask<?>> scheduledTaskQueue() {
    if (scheduledTaskQueue == null) {
        scheduledTaskQueue = new PriorityQueue<ScheduledFutureTask<?>>();
    }
    return scheduledTaskQueue;
}

<V> ScheduledFuture<V> schedule(final ScheduledFutureTask<V> task) {
    if (inEventLoop()) {
        scheduledTaskQueue().add(task);
    } else {
        execute(new Runnable() {
            @Override
            public void run() {
                scheduledTaskQueue().add(task);
            }
        });
    }

    return task;
}

• scheduledTaskQueue() -> 我理解为: 延迟创建 成员变量 scheduledTaskQueue

• inEventLoop() -> 如果是在同一Thread,就直接向成员变量中添加数据；否则,在一个新的Thread中添加, 这不会造成问题吗？

• 在什么条件下会出现 - 不是同一个线程的情况？

• 在 else 下， scheduledTaskQueue 重新初始化了一次吗？ 否则怎么保证安全啊？

• 有点方，没转过弯来，请各位道友帮帮忙……  

****

• 感谢 @鋒Nic 的回答，不过答案太长了也没分段看得我头疼。

• 我看到一句非常有价值的话是： 「外部线程发起的schedule的定时任务不应该去阻塞io事件的处理」 那是否是说进入到 else 的情形就是 那些会阻塞io事件的用户事件(我描述的不好，不知怎么描述)。  

• 我一直觉得 成员变量 scheduledTaskQueue 会随着这个类一起被重新创建多次 （如果进入到else里的话）
  

• 我感觉我还得仔细看看源码好好琢磨琢磨……
  

Answer 1

鋒Nic 2018-07-17 14:03:51

scheduledTaskQueue() 方法返回的是定时任务队列ScheduledTaskQueue，这边没延迟创建的意思。定时任务队列ScheduledTaskQueue在调用NioEventLoop的schedule()方法将Callable任务封装成ScheduledFutureTask,判断是否为当前NioEventLoop发起的schedule还是外部线程发起的schedule,当前NioEventLoop发起的schedule直接添加定时任务,外部线程发起的schedule为了保证线程安全(ScheduledTaskQueue是PriorityQueue非线程安全)添加定时任务操作当做普通任务Task保证对于定时任务队列操作都在NioEventLoop实现，外部线程发起的schedule的定时任务不应该去阻塞io事件的处理所以丢到定时任务队列ScheduledTaskQueue，在reactor线程第三步会从scheduledTaskQueue转移定时任务到taskQueue(mpsc queue)。

Queue<ScheduledFutureTask<?>> scheduledTaskQueue() {    

    if (scheduledTaskQueue == null) {        

        scheduledTaskQueue = new PriorityQueue<ScheduledFutureTask<?>>();    

    }    

    return scheduledTaskQueue; 

}

在Handler里调用schedule()方法，例如

ctx.channel().eventLoop().schedule(new Runnable() {    @Override
   public void run() {

   }
}, 60, TimeUnit.SECONDS);

• 提问者 南国漂泊 #1

  兄弟，看了你的解释，更晕啊

• 鋒Nic 回复 提问者 南国漂泊 #2

  哪里晕？

• 鋒Nic 回复 提问者 南国漂泊 #3

  https://www.jianshu.com/p/58fad8e42379附上闪电侠关于schedule任务的讲解。

点开查看后面1条评论