Author: trustin
Date: Tue Nov 13 21:49:06 2007
New Revision: 594780
URL: http://svn.apache.org/viewvc?rev=594780&view=rev
Log:
Optimized OrderedThreadPoolExecutor a little bit
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=594780&r1=594779&r2=594780&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
Tue Nov 13 21:49:06 2007
@@ -285,10 +285,9 @@
SessionBuffer buf = getSessionBuffer(s);
Queue<Runnable> queue = buf.queue;
boolean offerSession;
- boolean offeredEvent;
- synchronized (queue) {
- offeredEvent = queueHandler.accept(this, e);
- if (offeredEvent) {
+ boolean offerEvent = queueHandler.accept(this, e);
+ if (offerEvent) {
+ synchronized (queue) {
queue.offer(e);
if (buf.processingCompleted) {
buf.processingCompleted = false;
@@ -296,9 +295,9 @@
} else {
offerSession = false;
}
- } else {
- offerSession = false;
- }
+ }
+ } else {
+ offerSession = false;
}
if (offerSession) {
@@ -307,7 +306,7 @@
addWorkerIfNecessary();
- if (offeredEvent) {
+ if (offerEvent) {
queueHandler.offered(this, e);
}
}