File: multienginemap.py

package info (click to toggle)
ipython 0.13.1-2%2Bdeb7u1
  • links: PTS, VCS
  • area: main
  • in suites: wheezy
  • size: 15,752 kB
  • sloc: python: 69,537; makefile: 355; lisp: 272; sh: 80; objc: 37
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)