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);
         }
     }


Reply via email to