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

Comments

Browse Source
This commit is contained in:
Trustin Lee 2009-10-27 09:04:42 +00:00
parent 4ec06f7c78
commit 692c278cf9
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/jboss/netty/channel/socket/nio/NioDatagramWorker.java
View File

@ -125,7 +125,7 @@ class NioDatagramWorker implements Runnable {
*/ */
private final Queue<Runnable> writeTaskQueue = new LinkedTransferQueue<Runnable>(); private final Queue<Runnable> writeTaskQueue = new LinkedTransferQueue<Runnable>();
private volatile int cancelledKeys; private volatile int cancelledKeys; // should use AtomicInteger but we just need approximation
/** /**
* Sole constructor. * Sole constructor.

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

@ -76,7 +76,7 @@ class NioWorker implements Runnable {
private final Object startStopLock = new Object(); private final Object startStopLock = new Object();
private final Queue<Runnable> registerTaskQueue = new LinkedTransferQueue<Runnable>(); private final Queue<Runnable> registerTaskQueue = new LinkedTransferQueue<Runnable>();
private final Queue<Runnable> writeTaskQueue = new LinkedTransferQueue<Runnable>(); private final Queue<Runnable> writeTaskQueue = new LinkedTransferQueue<Runnable>();
private volatile int cancelledKeys; private volatile int cancelledKeys; // should use AtomicInteger but we just need approximation
NioWorker(int bossId, int id, Executor executor) { NioWorker(int bossId, int id, Executor executor) {
this.bossId = bossId; this.bossId = bossId;