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/08 10:02:16 UTC
svn commit: r593080 -
/mina/trunk/core/src/main/java/org/apache/mina/filter/executor/AbstractExecutorFilter.java
Author: trustin
Date: Thu Nov 8 01:02:08 2007
New Revision: 593080
URL: http://svn.apache.org/viewvc?rev=593080&view=rev
Log:
Fixed a problem that events are not executed simultaneously in the executor filter.
Modified:
mina/trunk/core/src/main/java/org/apache/mina/filter/executor/AbstractExecutorFilter.java
Modified: mina/trunk/core/src/main/java/org/apache/mina/filter/executor/AbstractExecutorFilter.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/executor/AbstractExecutorFilter.java?rev=593080&r1=593079&r2=593080&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/filter/executor/AbstractExecutorFilter.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/filter/executor/AbstractExecutorFilter.java Thu Nov 8 01:02:08 2007
@@ -24,7 +24,7 @@
import java.util.Collections;
import java.util.EnumSet;
import java.util.concurrent.Executor;
-import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
@@ -50,11 +50,12 @@
/**
* Creates a new instance with the default thread pool implementation
- * (<tt>new ThreadPoolExecutor(1, 16, 60, TimeUnit.SECONDS, new LinkedBlockingQueue() )</tt>).
+ * (<tt>new ThreadPoolExecutor(0, 16, 60, TimeUnit.SECONDS, new SynchronousQueue() )</tt>).
*/
protected AbstractExecutorFilter(IoEventType... eventTypes) {
- this(new ThreadPoolExecutor(1, 16, 60, TimeUnit.SECONDS,
- new LinkedBlockingQueue<Runnable>()), eventTypes);
+ this(new ThreadPoolExecutor(
+ 0, 16, 60, TimeUnit.SECONDS,
+ new SynchronousQueue<Runnable>()), eventTypes);
}
/**