removed unused code

[pmachines.git] / ya2 / engine / cbmux.py

diff --git a/ya2/engine/cbmux.py b/ya2/engine/cbmux.py
index 50047572672b6126eca644dd5b60be36014f418d..7b59c6a3aac54594e56377fbb14c5cebbc78b48f 100644 (file)
--- a/ya2/engine/cbmux.py
+++ b/ya2/engine/cbmux.py
@@ -1,22 +1,22 @@
-from threading import Lock
+# from threading import Lock
 
 
-class CallbackMux:
-    # this is a sort of "multiplexer" i.e. it manages callbacks from threads
-    # and redirect them to the main thread (this prevents deadlocks)
+# class CallbackMux:
+#     # this is a sort of "multiplexer" i.e. it manages callbacks from threads
+#     # and redirect them to the main thread (this prevents deadlocks)
 
-    def __init__(self):
-        self.lock = Lock()
-        self.callbacks = []
-        taskMgr.add(self.process_callbacks, 'processing callbacks')
+#     def __init__(self):
+#         self.lock = Lock()
+#         self.callbacks = []
+#         taskMgr.add(self.process_callbacks, 'processing callbacks')
 
-    def add_cb(self, func, args=None):
-        args = args or []
-        with self.lock: self.callbacks += [(func, args)]
+#     def add_cb(self, func, args=None):
+#         args = args or []
+#         with self.lock: self.callbacks += [(func, args)]
 
-    def process_callbacks(self, task):
-        with self.lock:
-            callbacks = self.callbacks[:]
-            self.callbacks = []
-        for func, args in callbacks: func(*args)
-        return task.cont
+#     def process_callbacks(self, task):
+#         with self.lock:
+#             callbacks = self.callbacks[:]
+#             self.callbacks = []
+#         for func, args in callbacks: func(*args)
+#         return task.cont