FilesExpand file tree

 master

/

multiengine2.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

29 lines (20 loc) · 794 Bytes

 master

/

multiengine2.py

Copy path

Top

File metadata and controls

• Code
• Blame

29 lines (20 loc) · 794 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

#-------------------------------------------------------------------------------

# Imports

#-------------------------------------------------------------------------------

from __future__ import print_function

import time

from IPython.parallel import Client

#-------------------------------------------------------------------------------

# Setup

#-------------------------------------------------------------------------------

mux = Client()[:]

mux.clear()

mux.block=False

ar1 = mux.apply(time.sleep, 5)

ar2 = mux.push(dict(a=10,b=30,c=range(20000),d='The dog went swimming.'))

ar3 = mux.pull(('a','b','d'), block=False)

print("Try a non-blocking get_result")

ar4 = mux.get_result()

print("Now wait for all the results")

mux.wait([ar1,ar2,ar3,ar4])

print("The last pull got:", ar4.r)