Changeset 108 for branches/supervisor/src/main/java/omq/server/RemoteThreadPool.java

Timestamp:

10/21/13 15:27:22 (11 years ago)

Author:

stoda

Message:

Refactoring to enable multinvocation thread done.
Now there's a multiinvocation thread which listens to the multiqueue

File:

• branches/supervisor/src/main/java/omq/server/RemoteThreadPool.java (modified) (4 diffs)

branches/supervisor/src/main/java/omq/server/RemoteThreadPool.java

@@ -23 +23 @@
         private static final Logger logger = Logger.getLogger(RemoteThreadPool.class.getName());
         private List<InvocationThread> workers;
+        private MultiInvocationThread multiWorker;
         private AtomicInteger busy;
         private int minPoolThreads;
@@ -34 +35 @@
         private boolean killed = false;
 
-        public RemoteThreadPool(int minPoolThreads, int maxPoolThreads, long refresh, long keepAliveTime, int maxMessagesPerThread, RemoteObject obj, Broker broker) {
+        public RemoteThreadPool(int minPoolThreads, int maxPoolThreads, long refresh, long keepAliveTime, int maxMessagesPerThread,
+                        RemoteObject obj, Broker broker) {
                 this.minPoolThreads = minPoolThreads;
                 this.maxPoolThreads = maxPoolThreads;
@@ -53 +55 @@
                  * Create and start minPoolThreads
                  */
-                logger.info("ObjectMQ reference: " + obj.getRef() + ", creating: " + minPoolThreads + ", maxPoolThreads: " + maxPoolThreads + ", refresh time: "
-                                + refresh + ", keepAlive: " + keepAliveTime + ", maxMessagesPerThread: " + maxMessagesPerThread);
+                logger.info("ObjectMQ reference: " + obj.getRef() + ", creating: " + minPoolThreads + ", maxPoolThreads: " + maxPoolThreads
+                                + ", refresh time: " + refresh + ", keepAlive: " + keepAliveTime + ", maxMessagesPerThread: " + maxMessagesPerThread);
+
+                try {
+                        multiWorker = new MultiInvocationThread(obj);
+                        multiWorker.start();
+                } catch (Exception e1) {
+                        // TODO Auto-generated catch block
+                        e1.printStackTrace();
+                }
 
                 for (int i = 0; i < minPoolThreads; i++) {
@@ -86 +96 @@
                                 } else if (numWorkers > minPoolThreads && busy.get() < numWorkers) {
                                         // Kill idle threads
-                                        System.out.println("Kill lazy workers, numWorkers = " + numWorkers + ", minPool = " + minPoolThreads + ", busy = " + busy.get());
+                                        System.out.println("Kill lazy workers, numWorkers = " + numWorkers + ", minPool = " + minPoolThreads + ", busy = "
+                                                        + busy.get());
                                         stopIdleThreads();
                                 }