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