andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Reduced unnecessary Thread.currentThread() calls

Browse Source
This commit is contained in:
Trustin Lee 2010-02-02 10:54:52 +00:00
parent 5269e64598
commit dd5354858e
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/jboss/netty/channel/socket/nio/NioWorker.java
View File

@ -483,14 +483,13 @@ class NioWorker implements Runnable {
} }
private void rescheduleWrite(final NioSocketChannel channel) { private void rescheduleWrite(final NioSocketChannel channel) {
final Thread currentThread = Thread.currentThread();
if (channel.writeTaskInTaskQueue.compareAndSet(false, true)) { if (channel.writeTaskInTaskQueue.compareAndSet(false, true)) {
boolean offered = writeTaskQueue.offer(channel.writeTask); boolean offered = writeTaskQueue.offer(channel.writeTask);
assert offered; assert offered;
} }
if (!(channel instanceof NioAcceptedSocketChannel) || if (!(channel instanceof NioAcceptedSocketChannel) ||
((NioAcceptedSocketChannel) channel).bossThread != currentThread) { ((NioAcceptedSocketChannel) channel).bossThread != Thread.currentThread()) {
final Selector workerSelector = selector; final Selector workerSelector = selector;
if (workerSelector != null) { if (workerSelector != null) {
if (wakenUp.compareAndSet(false, true)) { if (wakenUp.compareAndSet(false, true)) {