Don't rely on the return value fo Selector.select(..) as it is buggy and so can cause 100% cpu usage. See #535
This commit is contained in:
parent
573fbfa518
commit
5c6e3fe6ba
@ -242,7 +242,7 @@ class NioClientSocketPipelineSink extends AbstractNioChannelSink {
|
|||||||
wakenUp.set(false);
|
wakenUp.set(false);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
int selectedKeyCount = selector.select(10);
|
SelectorUtil.select(selector);
|
||||||
|
|
||||||
// 'wakenUp.compareAndSet(false, true)' is always evaluated
|
// 'wakenUp.compareAndSet(false, true)' is always evaluated
|
||||||
// before calling 'selector.wakeup()' to reduce the wake-up
|
// before calling 'selector.wakeup()' to reduce the wake-up
|
||||||
@ -277,10 +277,7 @@ class NioClientSocketPipelineSink extends AbstractNioChannelSink {
|
|||||||
}
|
}
|
||||||
|
|
||||||
processRegisterTaskQueue();
|
processRegisterTaskQueue();
|
||||||
|
processSelectedKeys(selector.selectedKeys());
|
||||||
if (selectedKeyCount > 0) {
|
|
||||||
processSelectedKeys(selector.selectedKeys());
|
|
||||||
}
|
|
||||||
|
|
||||||
// Handle connection timeout every 10 milliseconds approximately.
|
// Handle connection timeout every 10 milliseconds approximately.
|
||||||
long currentTimeNanos = System.nanoTime();
|
long currentTimeNanos = System.nanoTime();
|
||||||
|
Loading…
Reference in New Issue
Block a user