Skip to main content

submitting cpu-bound tasks to processes and io-bound tasks to threads

Project description

Convert a classic sequential program into a parallel one.


It runs faster.

What if not?

Don’t use it.


for image in images:
    create_thumbnail(image)       # original

for image in images:
    fork(create_thumbnail, image) # parallelized explicitly

for image in images:
    create_thumbnail(image)       # parallelized implictly (read below)

What about return values?

result = fork(my_func, *args, **kwargs)

And what is this result?

A future that behaves almost exactly as if it were the return value of my_func. That in turn means, as soon as you access the result and it is not ready yet, the main thread blocks.

Speaking of threads …

and processes? fork will take care of that for you.

You can assist fork by decorating your functions (not decorating defaults to cpu_bound):

def call_remote_webservice():
    # implementation

def fib(n):
    # naive implementation of Fibonacci numbers

@unsafe # don't fork; run sequentially
def weird_side_effects(*args, **kwargs):
    # implementation

Parallelize implicitly?

Use with caution; magic involved.

def create_thumbnail_by_webservice(image):
    # implementation

def create_thumbnail_by_bare_processing_power(image):
    # implementation

# the following two lines spawn two forks



  • easy way back and forth (from sequential to parallel and vice versa)
  • cascading possible (thread-safe)
  • compatible with Python 2 and 3


  • weird calling syntax (no syntax support)
  • type(result) == BlockingFuture
  • not working with coroutines (asyncio) yet
  • future is not contagious yet
  • not working with lambdas due to PickleError

Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for xfork, version 0.11
Filename, size File type Python version Upload date Hashes
Filename, size xfork-0.11-py2-none-any.whl (3.6 kB) File type Wheel Python version py2 Upload date Hashes View hashes
Filename, size xfork-0.11-py3-none-any.whl (3.6 kB) File type Wheel Python version py3 Upload date Hashes View hashes
Filename, size xfork-0.11.tar.gz (4.1 kB) File type Source Python version None Upload date Hashes View hashes

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page