Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import multiprocessing as mp
- pool = mp.Pool(processes=7, maxtasksperchild=1)
- all_items = [pool.apply_async(sub_process, args=(value,) for value in all_values]
- for item in all_items:
- item.get()
- import multiprocessing
- import logging
- import sys
- logger = logging.getLogger("mylogger")
- formatter = logging.Formatter('%(processName)s %(threadName)s [%(levelname)s] %(message)s')
- handler = logging.StreamHandler(stream=sys.stdout)
- handler.setFormatter(formatter)
- handler.setLevel(logging.DEBUG)
- logger.addHandler(handler)
- logger.setLevel(logging.DEBUG)
- def f(x):
- logger.info(multiprocessing.current_process())
- return x * x
- if __name__ == "__main__":
- logger.info("get started")
- p = multiprocessing.Pool()
- p.map(f, range(6))
- logger.info("done")
- MainProcess MainThread [INFO] get started
- ForkPoolWorker-1 MainThread [INFO] <ForkProcess(ForkPoolWorker-1, started daemon)>
- ForkPoolWorker-2 MainThread [INFO] <ForkProcess(ForkPoolWorker-2, started daemon)>
- ForkPoolWorker-3 MainThread [INFO] <ForkProcess(ForkPoolWorker-3, started daemon)>
- ForkPoolWorker-1 MainThread [INFO] <ForkProcess(ForkPoolWorker-1, started daemon)>
- ForkPoolWorker-4 MainThread [INFO] <ForkProcess(ForkPoolWorker-4, started daemon)>
- ForkPoolWorker-2 MainThread [INFO] <ForkProcess(ForkPoolWorker-2, started daemon)>
- MainProcess MainThread [INFO] done
- import os
- parent_pid = os.getpid()
- print "[parent] starts PID: %d" % (parent_pid, )
- from multiprocessing import Process
- import os
- def info(title):
- print(title)
- print('module name:', __name__)
- print('parent process:', os.getppid())
- print('process id:', os.getpid())
- from multiprocessing import current_process
- print(current_process().name == 'MainProcess')
Add Comment
Please, Sign In to add comment