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
|
import random
from Pyro5.api import expose, Daemon, Proxy, config
# We need to set either a socket communication timeout,
# or use the select based server. Otherwise the daemon requestLoop
# will block indefinitely and is never able to evaluate the loopCondition.
config.COMMTIMEOUT = 0.5
NUM_WORKERS = 5
class CallbackHandler(object):
workdone = 0
@expose
def done(self, number):
print("callback: worker %d reports work is done!" % number)
CallbackHandler.workdone += 1
with Daemon() as daemon:
# register our callback handler
callback = CallbackHandler()
daemon.register(callback)
# contact the server and put it to work
print("creating a bunch of workers")
with Proxy("PYRONAME:example.callback") as server:
for _ in range(NUM_WORKERS):
worker = server.addworker(callback) # provide our callback handler!
worker.work(random.randint(1, 5))
print("waiting for all work complete...")
daemon.requestLoop(loopCondition=lambda: CallbackHandler.workdone < NUM_WORKERS)
print("done!")
|
