Changeset 722

Timestamp:

10/14/03 14:45:38 (5 years ago)

Author:

sholloway

Message:

*** empty log message ***

Files:

• trunk/RBFoundation/RBFoundation/ThreadTools.py (modified) (1 diff)

trunk/RBFoundation/RBFoundation/ThreadTools.py

@@ -33 +33 @@
-class DispatchThread(threading.Thread):
-    def __init__(self):
-
-
-
+
+
+
+
-
-    def CallLater(self, callable, *args, **kw):
-
-
-
+
-
-_OnThreadExecute
+run
-        self._running = True
-        while self._running:
-workqueue.get(True
+_GetWork(
-            if callable is not None:
-                callable(*args, **kw)
-            else: break
+    def stop(self):
+        self._running = False
-
+    def _AddWork(self, item):
+        return self.workqueue.put(item, True)
+    def _GetWork(self):
+        return self.workqueue.get(True)
+    def _QueueFactory(self):
+        return Queue.Queue(None)
+
+#~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+
+class DictQueue(Queue.Queue):
+    def _init(self, maxsize=None):
+        self.maxsize = maxsize
+        self.queue = dict()
+
+    def _put(self, item):
+        self.queue[item[0]] = item[1]
+
+    def _get(self):
+        return self.queue.popitem()
+
+class DictDispatchThread(DispatchThread):
+    def CallLater(self, dispatchkey, callable, *args, **kw):
+        self._AddWork((dispatchkey, (callable, args, kw)))
+
+    def _QueueFactory(self):
+        return DictQueue()
+
+    def _GetWork(self):
+        return self.workqueue.get(True)[-1]
+