upstream/ipython Files · docs/examples/parallel/demo/map.py

use ROUTER/DEALER sockets for stdin...

use ROUTER/DEALER sockets for stdin stdin requests are now directed to the frontend that made the execution request that called raw_input. allow_stdin flag added to execution_request to indicate whether stdin_requests are allowed. StdInNotImplementedError exception class added to IPython.core.error, and is raised if raw_input is called from execute requests where allow_input is undefined. closes gh-673

Fernando Perez - - Load All Authors

File last commit:

r4910:0dc49390


                r4952:a2ac298e

Download file

             map.py
        
                    35 lines
            
             | 791 B
            
                | text/x-python
            
             |
                PythonLexer
            
             / docs / examples / parallel / demo / map.py
          
                    History
                
                 |
                  Annotation
                 | Raw
                 |Copy content
                 |Copy permalink

      from IPython.parallel import *

      client = Client()

      view = client.load_balanced_view()

      @view.remote(block=True)

      def square(a):

          """return square of a number"""

          return a*a

      squares = map(square, range(42))

      # but that blocked between each result; not exactly useful

      square.block = False

      arlist = map(square, range(42))

      # submitted very fast

      # wait for the results:

      squares2 = [ r.get() for r in arlist ]

      # now the more convenient @parallel decorator, which has a map method:

      view2 = client[:]

      @view2.parallel(block=False)

      def psquare(a):

          """return square of a number"""

          return a*a

      # this chunks the data into n-negines jobs, not 42 jobs:

      ar = psquare.map(range(42))

      # wait for the results to be done:

      squares3 = ar.get()

      print squares == squares2, squares3==squares

      # True

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

				from IPython.parallel import *

				client = Client()
				view = client.load_balanced_view()

				@view.remote(block=True)
				def square(a):
				"""return square of a number"""
				return a*a

				squares = map(square, range(42))

				# but that blocked between each result; not exactly useful

				square.block = False

				arlist = map(square, range(42))
				# submitted very fast

				# wait for the results:
				squares2 = [ r.get() for r in arlist ]

				# now the more convenient @parallel decorator, which has a map method:
				view2 = client[:]
				@view2.parallel(block=False)
				def psquare(a):
				"""return square of a number"""
				return a*a

				# this chunks the data into n-negines jobs, not 42 jobs:
				ar = psquare.map(range(42))

				# wait for the results to be done:
				squares3 = ar.get()
				print squares == squares2, squares3==squares
				# True