Guest User

Untitled

a guest
May 20th, 2018
126
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.70 KB | None | 0 0
  1. import multiprocessing as mp
  2.  
  3. pool = mp.Pool(processes=7, maxtasksperchild=1)
  4.  
  5. all_items = [pool.apply_async(sub_process, args=(value,) for value in all_values]
  6. for item in all_items:
  7. item.get()
  8.  
  9. import multiprocessing
  10. import logging
  11. import sys
  12. logger = logging.getLogger("mylogger")
  13.  
  14. formatter = logging.Formatter('%(processName)s %(threadName)s [%(levelname)s] %(message)s')
  15.  
  16. handler = logging.StreamHandler(stream=sys.stdout)
  17. handler.setFormatter(formatter)
  18. handler.setLevel(logging.DEBUG)
  19.  
  20. logger.addHandler(handler)
  21. logger.setLevel(logging.DEBUG)
  22.  
  23. def f(x):
  24. logger.info(multiprocessing.current_process())
  25. return x * x
  26.  
  27. if __name__ == "__main__":
  28. logger.info("get started")
  29. p = multiprocessing.Pool()
  30. p.map(f, range(6))
  31. logger.info("done")
  32.  
  33. MainProcess MainThread [INFO] get started
  34. ForkPoolWorker-1 MainThread [INFO] <ForkProcess(ForkPoolWorker-1, started daemon)>
  35. ForkPoolWorker-2 MainThread [INFO] <ForkProcess(ForkPoolWorker-2, started daemon)>
  36. ForkPoolWorker-3 MainThread [INFO] <ForkProcess(ForkPoolWorker-3, started daemon)>
  37. ForkPoolWorker-1 MainThread [INFO] <ForkProcess(ForkPoolWorker-1, started daemon)>
  38. ForkPoolWorker-4 MainThread [INFO] <ForkProcess(ForkPoolWorker-4, started daemon)>
  39. ForkPoolWorker-2 MainThread [INFO] <ForkProcess(ForkPoolWorker-2, started daemon)>
  40. MainProcess MainThread [INFO] done
  41.  
  42. import os
  43.  
  44. parent_pid = os.getpid()
  45. print "[parent] starts PID: %d" % (parent_pid, )
  46.  
  47. from multiprocessing import Process
  48. import os
  49.  
  50. def info(title):
  51. print(title)
  52. print('module name:', __name__)
  53. print('parent process:', os.getppid())
  54. print('process id:', os.getpid())
  55.  
  56. from multiprocessing import current_process
  57. print(current_process().name == 'MainProcess')
Add Comment
Please, Sign In to add comment