在前面我們已經(jīng)知道了，NioEventLoop 本身就是一個SingleThreadEventExecutor，因此NioEventLoop 的啟動，其實就是NioEventLoop 所綁定的本地Java 線程的啟動。

按照這個思路，我們只需要找到在哪里調(diào)用了SingleThreadEventExecutor 中thread 字段的start()方法就可以知道是在哪里啟動的這個線程了。從前面章節(jié)的分析中， 其實我們已經(jīng)清楚： thread.start() 被封裝到了SingleThreadEventExecutor.startThread()方法中，來看代碼：

private void startThread() {if (STATE_UPDATER.get(this) == ST_NOT_STARTED) {if (STATE_UPDATER.compareAndSet(this, ST_NOT_STARTED, ST_STARTED)) {doStartThread();}} }

STATE_UPDATER 是SingleThreadEventExecutor 內(nèi)部維護(hù)的一個屬性，它的作用是標(biāo)識當(dāng)前的thread 的狀態(tài)。在初始的時候，STATE_UPDATER == ST_NOT_STARTED，因此第一次調(diào)用startThread()方法時，就會進(jìn)入到if 語句內(nèi)，進(jìn)而調(diào)用到thread.start()方法。而這個關(guān)鍵的startThread()方法又是在哪里調(diào)用的呢?用方法調(diào)用關(guān)系反向查找功能，我們發(fā)現(xiàn)，startThread 是在SingleThreadEventExecutor 的execute()方法中調(diào)用的：

public void execute(Runnable task) {if (task == null) {throw new NullPointerException("task");}boolean inEventLoop = inEventLoop();if (inEventLoop) {addTask(task);} else {startThread(); // 調(diào)用startThread 方法、啟動EventLoop 線程addTask(task);if (isShutdown() && removeTask(task)) {reject();}}if (!addTaskWakesUp && wakesUpForTask(task)) {wakeup(inEventLoop);} }

既然如此，那現(xiàn)在我們的工作就變?yōu)榱藢ふ以谀睦锏谝淮握{(diào)用了SingleThreadEventExecutor 的execute()方法。

如果細(xì)心的小伙伴可能已想到了, 我們在前面章節(jié)中， 我們有提到到在注冊channel 的過程中， 會在AbstractChannel$AbstractUnsafe 的register()中調(diào)用eventLoop.execute()方法，在EventLoop 中進(jìn)行Channel 注冊代碼的執(zhí)行，AbstractChannel$AbstractUnsafe 的register()部分代碼如下：

public final void register(EventLoop eventLoop, final ChannelPromise promise) {// 刪除判斷AbstractChannel.this.eventLoop = eventLoop;if (eventLoop.inEventLoop()) {register0(promise);} else {try {eventLoop.execute(new Runnable() {@Overridepublic void run() {register0(promise);}});} catch (Throwable t) {// 刪除異常處理代碼}} }

很顯然，一路從Bootstrap 的bind()方法跟蹤到AbstractChannel$AbstractUnsafe 的register()方法，整個代碼都是在主線程中運行的，因此上面的eventLoop.inEventLoop()返回為false，于是進(jìn)入到else 分支，在這個分支中調(diào)用了eventLoop.execute()方法，而NioEventLoop 沒有實現(xiàn)execute()方法，因此調(diào)用的是SingleThreadEventExecutor 的execute()方法：

public void execute(Runnable task) {// 條件判斷boolean inEventLoop = inEventLoop();if (inEventLoop) {addTask(task);} else {startThread();addTask(task);if (isShutdown() && removeTask(task)) {reject();}}if (!addTaskWakesUp && wakesUpForTask(task)) {wakeup(inEventLoop);} }

我們已經(jīng)分析過了， inEventLoop == false ， 因此執(zhí)行到else 分支， 在這里就調(diào)用startThread() 方法來啟動SingleThreadEventExecutor 內(nèi)部關(guān)聯(lián)的Java 本地線程了。

總結(jié)一句話：當(dāng)EventLoop 的execute()第一次被調(diào)用時，就會觸發(fā)startThread()方法的調(diào)用，進(jìn)而導(dǎo)致EventLoop所對應(yīng)的Java 本地線程啟動。

?

總結(jié)

以上是生活随笔為你收集整理的EventLoop 的启动的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。