Changeset 101 for branches/supervisor/src/main/java/omq/server/RemoteObject.java

Timestamp:

10/11/13 13:44:19 (11 years ago)

Author:

stoda

Message:

PoolThreadSupervisor? done

TODO: revise all threads

File:

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

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

@@ -35 +35 @@
         private transient RemoteThreadPool pool;
         private transient Map<String, List<Class<?>>> params;
-        private transient List<InvocationThread> invocationList;
 
         private static final Map<String, Class<?>> primitiveClasses = new HashMap<String, Class<?>>();
@@ -74 +73 @@
                 }
 
-                // Get num threads to use
-                int numThreads = Integer.parseInt(env.getProperty(ParameterQueue.NUM_THREADS, "1"));
-                invocationList = new ArrayList<InvocationThread>(numThreads);
-
-                // Start invocation threads
-                for (int i = 0; i < numThreads; i++) {
-                        InvocationThread iThread = new InvocationThread(this, broker);
-                        invocationList.add(iThread);
-                        iThread.start();
-                }
-
+                // Get pool information
+                int minPoolThreads = Integer.parseInt(env.getProperty(ParameterQueue.MIN_POOL_THREADS, "1"));
+                int maxPoolThreads = Integer.parseInt(env.getProperty(ParameterQueue.MAX_POOL_THREADS, "1"));
+                long refresh = Long.parseLong(env.getProperty(ParameterQueue.POOL_REFRESH_TIME, "60000"));
+                long keepAliveTime = Long.parseLong(env.getProperty(ParameterQueue.KEEP_ALIVE_TIME, "30000"));
+                int maxMessagesPerThread = Integer.parseInt(env.getProperty(ParameterQueue.MAX_MESSAGES_PER_THREAD, "5"));
+
+                // Create the pool & start it
+                pool = new RemoteThreadPool(minPoolThreads, maxPoolThreads, refresh, keepAliveTime, maxMessagesPerThread, this, broker);
+                pool.start();
         }
 
@@ -100 +98 @@
         public void kill() throws IOException {
                 logger.info("Killing objectmq: " + this.getRef());
-                for (InvocationThread iThread : invocationList) {
-                        iThread.kill();
-                }
+                pool.kill();
         }
 
@@ -205 +201 @@
         }
 
+        public RemoteThreadPool getPool() {
+                return pool;
+        }
+
         public Properties getEnv() {
                 return env;