Skip to content

Instantly share code, notes, and snippets.

@limafm
Created July 5, 2018 15:40
Show Gist options
  • Save limafm/9f655a85ac57525f3bb9f2caee75a9fd to your computer and use it in GitHub Desktop.
Save limafm/9f655a85ac57525f3bb9f2caee75a9fd to your computer and use it in GitHub Desktop.
Python multiprocessing
import multiprocessing
import time
from random import randint
PROCESSES = 5
WORKER_CALLS = 7
def worker(num):
"""worker function"""
print 'Starting worker', num
time.sleep(randint(2,4))
print 'Exiting worker', num
return "ok"
if __name__ == '__main__':
pool = multiprocessing.Pool(processes=PROCESSES)
pool_outputs = pool.map(worker, range(WORKER_CALLS))
pool.close()
pool.join()
print 'Pool:', pool_outputs
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment