概述
首先整个循环是个死循环，进行事件监测 select的方法做了三件事：
- 必要的逻辑判断。
- 阻塞式select操作。
- 避免jdk空轮训bug。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
//NioEventLoop.java
@Override
protected void run() {
for (; ; ) {
try {
switch (selectStrategy.calculateStrategy(selectNowSupplier, hasTasks())) {
...
case SelectStrategy.SELECT:
//检测IO事件
select(wakenUp.getAndSet(false));
...
}
...
}
...
}
}
因为这段代码过长，所以解释方法就直接写在代码里面了方便查看
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
//NioEventLoop.java
private void select(boolean oldWakenUp) throws IOException {
Selector selector = this.selector;
try {
int selectCnt = 0; //记录轮训次数（主要针对空轮训计数）
long currentTimeNanos = System.nanoTime(); //当前时间
//delayNanos(currentTimeNanos)获取延迟任务队列中第一个任务截止时间，
//如果返回时空则默认1s，selectDeadLineNanos是记录这次select操作的截止时间。
long selectDeadLineNanos = currentTimeNanos + delayNanos(currentTimeNanos);
for (; ; ) {
// 本次select任务超时时间 500000L做个微调值 除1000000L 是为了纳秒转为毫秒
long timeoutMillis = (selectDeadLineNanos - currentTimeNanos + 500000L) / 1000000L;
if (timeoutMillis <= 0) {// 时间不足1ms，不再进行select操作。
if (selectCnt == 0) {//一次select操作没有进行
selector.selectNow();//非堵塞的select方法 立即返回事件
selectCnt = 1;
}
break;
}
/*轮询过程中发现有任务加入，中断本次轮询。
* netty为了保证任务队列能够及时执行，在进行阻塞select操作的时候会判断任务队列是否为空，
*如果不为空，就执行一次非阻塞select操作，跳出循环
*/
if (hasTasks() && wakenUp.compareAndSet(false, true)) {
selector.selectNow();//非堵塞select方法
selectCnt = 1;
break;
}
//堵塞， 调用了 selector.select(timeoutMillis), 而这个调用是会阻塞住当前线程的, timeoutMillis 是阻塞的超时时间.
int selectedKeys = selector.select(timeoutMillis);
selectCnt++;
//说明有任务或者有正在处理的任务，
if (selectedKeys != 0 || oldWakenUp || wakenUp.get() || hasTasks() || hasScheduledTasks()) {
// - Selected something,
// - waken up by user, or
// - the task queue has a pending task.
// - a scheduled task is ready for processing
break;
}
//线程断了。。。
if (Thread.interrupted()) {
if (logger.isDebugEnabled()) {
...
}
selectCnt = 1;
break;
}
//到这个地方已经发生过堵塞操作 记录时间
long time = System.nanoTime();
//time - currentTimeNanos 小于TimeUnit.MILLISECONDS.toNanos(timeoutMillis)
//完成一次堵塞操作的时间 - 轮训前的时间 < 任务超时时间 说明实际上没有发生堵塞 ，空轮训了。。
/**
* 大致可以这么看 ，执行select前记录下时间 30s ， 执行一个select时间要60s , 执行select后 记录时间 50s
* [如果执行select后的时间] - [执行selelct需要的时间] < [执行select前记录时间] ，说明了 这个select 操作是没有发生，空轮循了一次
*/
if (time - TimeUnit.MILLISECONDS.toNanos(timeoutMillis) >= currentTimeNanos) {
selectCnt = 1;
} else if (SELECTOR_AUTO_REBUILD_THRESHOLD > 0 &&
selectCnt >= SELECTOR_AUTO_REBUILD_THRESHOLD) {//512次
//大于一个阈值 默认512
//老的select重新注册新的selector 防止空轮训
rebuildSelector();
selector = this.selector;
selector.selectNow();
selectCnt = 1;
break;
}
currentTimeNanos = time;
}
...
}
