EventLoop execute() 怎么保证线程安全

EventLoop 的 execute() 是在 SingleThreadEventLoop 中实现的。

    @Override
    public void execute(Runnable task) {
        if (task == null) {
            throw new NullPointerException("task");
        }

        boolean inEventLoop = inEventLoop();
        if (inEventLoop) {
            addTask(task);
        } else {
            startThread();
            addTask(task);
            if (isShutdown() && removeTask(task)) {
                reject();
            }
        }

        if (!addTaskWakesUp && wakesUpForTask(task)) {
            wakeup(inEventLoop);
        }
    }

如果是在 eventLoop 线程里，则直接插入到 任务队列，没有竞争问题。

如果不在则保证 eventLoop 线程已经启动了。然后在把任务添加到队列中。由于队列使用的是 LinkedBlockQueue 所以是线程安全的。

添加到队列之后结合 EventLoop 源码分析篇 相关文章，可以知道 eventloop 线程在每次处理完事件之后，会拿出一部分事件片处理队列里的 task。代码片段如下。 runAllTasks() 方法。

 //ioRatio 为 100 的时候就执行完 io 事件之后执行所有的 task
                if (ioRatio == 100) {
                    try {
                        processSelectedKeys();
                    } finally {
                        // Ensure we always run tasks.
                        runAllTasks();
                    }
                } else {
                    final long ioStartTime = System.nanoTime();
                    try {
                        //处理有事件发生的 key
                        processSelectedKeys();
                    } finally {
                        // Ensure we always run tasks.
                        final long ioTime = System.nanoTime() - ioStartTime;
                        //计算出执行普通任务占的百分比
                        runAllTasks(ioTime * (100 - ioRatio) / ioRatio);
                    }
                }