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

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

File:

• branches/supervisor/src/main/java/omq/server/InvocationThread.java (modified) (5 diffs)

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;
+        }
+
 }