|
@@ -11,6 +11,8 @@ import subprocess
|
|
|
from sets import Set
|
|
|
import re
|
|
|
import datetime
|
|
|
+import Queue
|
|
|
+
|
|
|
|
|
|
class Analysis:
|
|
|
def __init__(self):
|
|
@@ -182,3 +184,11 @@ class DetailProcess(Analysis):
|
|
|
#return [{"memory_usage":row[0],"cpu_usage":row[1],"memory_available":row[2]/1000,"label":row[3]} for row in ma]
|
|
|
|
|
|
return ma
|
|
|
+
|
|
|
+class QListener(Thread)
|
|
|
+ def __init__(self,handlers):
|
|
|
+ self.handlers = handlers
|
|
|
+ self.queue = Queue.LifoQueue()
|
|
|
+ def post(self) :
|
|
|
+ for handler in self.handlers:
|
|
|
+ self.queue.put(handler.)
|