You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by tr...@apache.org on 2007/11/09 03:53:03 UTC
svn commit: r593408 -
/mina/trunk/core/src/main/java/org/apache/mina/filter/executor/OrderedThreadPoolExecutor.java
Author: trustin
Date: Thu Nov 8 18:53:03 2007
New Revision: 593408
URL: http://svn.apache.org/viewvc?rev=593408&view=rev
Log:
Renamed waitingSessionQueue to waitingSessions (my fingers hurt)
Modified:
mina/trunk/core/src/main/java/org/apache/mina/filter/executor/OrderedThreadPoolExecutor.java
Modified: mina/trunk/core/src/main/java/org/apache/mina/filter/executor/OrderedThreadPoolExecutor.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/executor/OrderedThreadPoolExecutor.java?rev=593408&r1=593407&r2=593408&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/filter/executor/OrderedThreadPoolExecutor.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/filter/executor/OrderedThreadPoolExecutor.java Thu Nov 8 18:53:03 2007
@@ -51,7 +51,7 @@
private static final IoSession EXIT_SIGNAL = new DummySession();
private final AttributeKey BUFFER = new AttributeKey(getClass(), "queue");
- private final BlockingQueue<IoSession> waitingSessionQueue = new LinkedBlockingQueue<IoSession>();
+ private final BlockingQueue<IoSession> waitingSessions = new LinkedBlockingQueue<IoSession>();
private final Set<Worker> workers = new HashSet<Worker>();
@@ -141,7 +141,7 @@
if (workers.size() <= corePoolSize) {
return;
}
- waitingSessionQueue.offer(EXIT_SIGNAL);
+ waitingSessions.offer(EXIT_SIGNAL);
}
}
@@ -207,7 +207,7 @@
synchronized (workers) {
for (int i = workers.size(); i > 0; i --) {
- waitingSessionQueue.offer(EXIT_SIGNAL);
+ waitingSessions.offer(EXIT_SIGNAL);
}
}
}
@@ -218,9 +218,9 @@
List<Runnable> answer = new ArrayList<Runnable>();
IoSession session;
- while ((session = waitingSessionQueue.poll()) != null) {
+ while ((session = waitingSessions.poll()) != null) {
if (session == EXIT_SIGNAL) {
- waitingSessionQueue.offer(EXIT_SIGNAL);
+ waitingSessions.offer(EXIT_SIGNAL);
Thread.yield(); // Let others take the signal.
continue;
}
@@ -259,7 +259,7 @@
}
if (offer) {
- waitingSessionQueue.offer(s);
+ waitingSessions.offer(s);
}
addWorkerIfNecessary();
@@ -448,7 +448,7 @@
}
try {
- session = waitingSessionQueue.poll(waitTime, TimeUnit.MILLISECONDS);
+ session = waitingSessions.poll(waitTime, TimeUnit.MILLISECONDS);
break;
} finally {
if (session == null) {