multienginemap.py
19 lines
| 454 B
| text/x-python
|
PythonLexer
Thomas Kluyver
|
r6455 | from __future__ import print_function | ||
MinRK
|
r3670 | from IPython.parallel import Client | ||
rc = Client() | ||||
view = rc[:] | ||||
result = view.map_sync(lambda x: 2*x, range(10)) | ||||
Thomas Kluyver
|
r6455 | print("Simple, default map: ", result) | ||
MinRK
|
r3670 | |||
ar = view.map_async(lambda x: 2*x, range(10)) | ||||
Thomas Kluyver
|
r6455 | print("Submitted map, got AsyncResult: ", ar) | ||
MinRK
|
r3670 | result = ar.r | ||
Thomas Kluyver
|
r6455 | print("Using map_async: ", result) | ||
MinRK
|
r3670 | |||
@view.parallel(block=True) | ||||
def f(x): return 2*x | ||||
MinRK
|
r4184 | result = f.map(range(10)) | ||
Thomas Kluyver
|
r6455 | print("Using a parallel function: ", result) | ||