[infinispan-commits] Infinispan SVN: r1655 - trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty.

[infinispan-commits at lists.jboss.org]

Author: mircea.markus
Date: 2010-04-01 18:24:05 -0400 (Thu, 01 Apr 2010)
New Revision: 1655

Modified:
   trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyTransport.scala
Log:
workaround

Modified: trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyTransport.scala
===================================================================
--- trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyTransport.scala	2010-04-01 21:32:14 UTC (rev 1654)
+++ trunk/server/core/src/main/scala/org/infinispan/server/core/transport/netty/NettyTransport.scala	2010-04-01 22:24:05 UTC (rev 1655)
@@ -40,17 +40,22 @@
          Executors.newFixedThreadPool(masterThreads, tf)
       }
    }
-   lazy val workerExecutor = {
+   //todo investigate the actual reason why multiple threads do not work
+   lazy val workerExecutor =  {
       val tf = new NamedThreadFactory(cacheName + '-' + "Worker")
-      if (workerThreads == 0) {
-         debug("Configured unlimited threads for worker thread pool")
-         Executors.newCachedThreadPool(tf)
-      }
-      else {
-         debug("Configured {0} threads for worker thread pool", workerThreads)
-         Executors.newFixedThreadPool(workerThreads, tf)
-      }      
+      Executors.newSingleThreadExecutor(tf)
    }
+//   lazy val workerExecutor = {
+//      val tf = new NamedThreadFactory(cacheName + '-' + "Worker")
+//      if (workerThreads == 0) {
+//         debug("Configured unlimited threads for worker thread pool")
+//         Executors.newCachedThreadPool(tf)
+//      }
+//      else {
+//         debug("Configured {0} threads for worker thread pool", workerThreads)
+//         Executors.newFixedThreadPool(workerThreads, tf)
+//      }
+//   }
 
    override def start {
       val bootstrap = new ServerBootstrap(factory);