Repository URL to install this package:
|
Version:
0.13.2 ▾
|
from __future__ import print_function
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
result = f.map(range(10))
print("Using a parallel function: ", result)