File: multienginemap.py

package info (click to toggle)
ipython 1.2.1-2~bpo70%2B1
  • links: PTS, VCS
  • area: main
  • in suites: wheezy-backports
  • size: 22,884 kB
  • sloc: python: 67,305; makefile: 469; lisp: 272; sh: 251
file content (19 lines) | stat: -rw-r--r-- 454 bytes parent folder | download | duplicates (2) 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
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)