Changeset 100 for branches/supervisor/src/main/java/omq/server

Timestamp:

10/09/13 17:35:41 (11 years ago)

Author:

stoda

Message:

Idea of thread supervisor done

TODO test the idea, change the remote properties, etc

Location:

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

Files:

• InvocationThread.java (modified) (5 diffs)
• RemoteObject.java (modified) (1 diff)
• RemoteThreadPool.java (added)

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

@@ -37 +37 @@
         private String UID;
         private Properties env;
+        private boolean idle;
+        private long lastExec;
+
+        private RemoteThreadPool pool; // TODO posar això bé
 
         // Broker
@@ -54 +58 @@
                 this.broker = broker;
                 this.serializer = broker.getSerializer();
+                this.lastExec = 0;
+                this.idle = true;
         }
 
@@ -73 +79 @@
                                 // Get the delivery
                                 Delivery delivery = consumer.nextDelivery();
+
+                                // This thread gets busy
+                                pool.getBusy().incrementAndGet();
+                                idle = false;
 
                                 String serializerType = delivery.getProperties().getType();
@@ -112 +122 @@
 
                                 channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
+
+                                // The thread is now idle
+                                lastExec = System.currentTimeMillis();
+                                idle = true;
+                                pool.getBusy().decrementAndGet();
+
                         } catch (InterruptedException i) {
                                 logger.error(i);
@@ -231 +247 @@
         }
 
+        public long getLastExecution() {
+                return lastExec;
+        }
+
+        public boolean isIdle() {
+                return idle;
+        }
+
 }

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

@@ -33 +33 @@
         private Properties env;
         private transient Broker broker;
+        private transient RemoteThreadPool pool;
         private transient Map<String, List<Class<?>>> params;
         private transient List<InvocationThread> invocationList;