python MulitProcessing 처리 방법 3가지 예제

multi_process1.py

#!/usr/bin/python
# -*- coding: utf-8 -*-
import multiprocessing
import random
import time

def worker(num):
    for i in range(5):
    	print("{0},  {1}".format(num, i))
    return

if __name__ == '__main__':
    jobs = []
    for i in range(5):
        p = multiprocessing.Process(target=worker, args=(i,))
        jobs.append(p)
        p.start()

    # Iterate through the list of jobs and remove one that are finished, checking every second.
    for job in jobs:
    	job.join()

    print('*** All jobs finished ***')

multi_process2.py

#!/usr/bin/python
# -*- coding: utf-8 -*-
from multiprocessing import Pool
import random, time

def worker(num):
    for i in range(5):
    	print("{0},  {1}".format(num, i))
    return

if __name__ == '__main__':
    
    pool = Pool(processes=4)
    pool.map(worker, range(5))

    print('*** All jobs finished ***')

multi_process3.py

#!/usr/bin/python
# -*- coding: utf-8 -*-
from multiprocessing import Pool
import random, time

def worker(num):
    for i in range(5):
    	print("{0},  {1}".format(num, i))
    return

if __name__ == '__main__':
    
    with Pool(processes=4) as pool:
        pool.map(worker, range(5))

    pool.join()
    print('*** All jobs finished ***')