1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
|
#!/usr/bin/env python3
#
# Copyright (c) ZeroC, Inc. All rights reserved.
#
import Ice, os, sys, traceback, time, threading
def test(b):
if not b:
raise RuntimeError('test assertion failed')
class Dispatcher:
def __init__(self):
self._calls = []
self._terminated = False
self._cond = threading.Condition()
self._thread = threading.Thread(target=self.run)
self._thread.start()
Dispatcher._instance = self
def dispatch(self, call, con):
with self._cond:
self._calls.append(call)
if len(self._calls) == 1:
self._cond.notify()
def run(self):
while True:
call = None
with self._cond:
while not self._terminated and len(self._calls) == 0:
self._cond.wait()
if len(self._calls) > 0:
call = self._calls.pop(0)
elif self._terminated:
# Terminate only once all calls are dispatched.
return
if call:
try:
call()
except:
# Exceptions should never propagate here.
test(False)
@staticmethod
def terminate():
with Dispatcher._instance._cond:
Dispatcher._instance._terminated = True
Dispatcher._instance._cond.notify()
Dispatcher._instance._thread.join()
Dispatcher._instance = None
@staticmethod
def isDispatcherThread():
return threading.current_thread() == Dispatcher._instance._thread
@staticmethod
def instance():
return Dispatcher._instance
|
