[jboss-cvs] JBoss Messaging SVN: r5586 - trunk/src/main/org/jboss/messaging/core/paging/impl.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2009-01-06 16:25:44 -0500 (Tue, 06 Jan 2009)
New Revision: 5586

Modified:
   trunk/src/main/org/jboss/messaging/core/paging/impl/PagingStoreFactoryNIO.java
Log:
fixed thread pool

Modified: trunk/src/main/org/jboss/messaging/core/paging/impl/PagingStoreFactoryNIO.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/paging/impl/PagingStoreFactoryNIO.java	2009-01-06 21:22:23 UTC (rev 5585)
+++ trunk/src/main/org/jboss/messaging/core/paging/impl/PagingStoreFactoryNIO.java	2009-01-06 21:25:44 UTC (rev 5586)
@@ -37,8 +37,7 @@
 import java.util.List;
 import java.util.concurrent.Executor;
 import java.util.concurrent.ExecutorService;
-import java.util.concurrent.SynchronousQueue;
-import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 
 import org.jboss.messaging.core.journal.SequentialFileFactory;
@@ -93,13 +92,8 @@
    {
       this.directory = directory;
 
-      parentExecutor = new ThreadPoolExecutor(0,
-                                              maxThreads,
-                                              60L,
-                                              TimeUnit.SECONDS,
-                                              new SynchronousQueue<Runnable>(),
-                                              new JBMThreadFactory("JBM-depaging-threads"));
-
+      parentExecutor = Executors.newFixedThreadPool(maxThreads, new JBMThreadFactory("JBM-depaging-threads"));
+   
       executorFactory = new OrderedExecutorFactory(parentExecutor);
 
       globalDepagerExecutor = executorFactory.getExecutor();