Advertisement
Guest User

Untitled

a guest
Jun 19th, 2019
88
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.61 KB | None | 0 0
  1. #!/bin/python
  2. import time
  3. import multiprocessing as mp
  4.  
  5.  
  6. class Job(object):
  7. def __init__(self, target, *a, **kw):
  8. self.target = target
  9. self.args = a
  10. self.kwargs = kw
  11.  
  12. def parallelize(jobs):
  13. """
  14. Args:
  15. jobs (list): list of the jobs to run. with all its params
  16. """
  17. procs = [mp.Process(target=job.target, args=job.args, kwargs=job.kwargs) for job in jobs]
  18. for p in procs:
  19. p.start()
  20. for p in procs:
  21. p.join()
  22.  
  23.  
  24. def dummy(*a, **kw):
  25. print a
  26. time.sleep(1)
  27. print kw
  28.  
  29.  
  30. def main():
  31. parallelize([Job(dummy) for i in range(2)])
  32.  
  33. main()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement