[GNUnet-SVN] r22718 - gnunet-planetlab/gplmt

[gnunet]

Author: wachs
Date: 2012-07-17 16:09:23 +0200 (Tue, 17 Jul 2012)
New Revision: 22718

Modified:
   gnunet-planetlab/gplmt/Worker.py
Log:
- worker

Modified: gnunet-planetlab/gplmt/Worker.py
===================================================================
--- gnunet-planetlab/gplmt/Worker.py    2012-07-17 13:42:41 UTC (rev 22717)
+++ gnunet-planetlab/gplmt/Worker.py    2012-07-17 14:09:23 UTC (rev 22718)
@@ -22,6 +22,31 @@
 #
 # Nodes
 
+import threading
+import time
+
+exitFlag = 0
+
+def print_time(threadName, delay, counter):
+    while counter:
+        if exitFlag:
+            thread.exit()
+        time.sleep(delay)
+        print "%s: %s" % (threadName, time.ctime(time.time()))
+        counter -= 1
+
+class NodeWorkerThread (threading.Thread):
+    def __init__(self, threadID, name, counter):
+        self.threadID = threadID
+        self.name = name
+        self.counter = counter
+        threading.Thread.__init__(self)
+    def run(self):
+        print "Starting " + self.name
+        print_time(self.name, self.counter, 5)
+        print "Exiting " + self.name
+
+
 class NodeWorker:
     def __init__(self, logger, node, tasks):
         assert (None != logger)