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