helloworld.py
19 lines
| 424 B
| text/x-python
|
PythonLexer
MinRK
|
r3664 | """ | ||
A Distributed Hello world | ||||
Ken Kinder <ken@kenkinder.com> | ||||
""" | ||||
MinRK
|
r3666 | from IPython.parallel import Client | ||
MinRK
|
r3664 | |||
MinRK
|
r3666 | rc = Client() | ||
MinRK
|
r3664 | |||
def sleep_and_echo(t, msg): | ||||
import time | ||||
time.sleep(t) | ||||
return msg | ||||
view = rc.load_balanced_view() | ||||
world = view.apply_async(sleep_and_echo, 3, 'World!') | ||||
hello = view.apply_async(sleep_and_echo, 2, 'Hello') | ||||
print "Submitted tasks:", hello.msg_ids, world.msg_ids | ||||
print hello.get(), world.get() | ||||