- def __init__(self, world, queues_out):
- self.world = world
+ def __init__(self, queues_out):
+ from multiprocessing import Pool
def send_to(self, connection_id, msg):
"""Send msg to client of connection_id."""
def send_to(self, connection_id, msg):
"""Send msg to client of connection_id."""
Numbers are calculated in parallel as far as possible, using fib().
A 'CALCULATING …' message is sent to caller before the result.
"""
Numbers are calculated in parallel as far as possible, using fib().
A 'CALCULATING …' message is sent to caller before the result.
"""
fib_fail = 'MALFORMED FIB REQUEST'
if len(tokens) < 2:
self.send_to(connection_id, fib_fail)
fib_fail = 'MALFORMED FIB REQUEST'
if len(tokens) < 2:
self.send_to(connection_id, fib_fail)
self.send_to(connection_id, fib_fail)
return
self.send_to(connection_id, 'CALCULATING …')
self.send_to(connection_id, fib_fail)
return
self.send_to(connection_id, 'CALCULATING …')
reply = ' '.join([str(r) for r in results])
self.send_to(connection_id, reply)
reply = ' '.join([str(r) for r in results])
self.send_to(connection_id, reply)