Python实现多进程的详解（附示例）(2)-木庄网络博客

可以通过创建类的方式实现多进程：

from multiprocessing import Process
import time
 
 
class My_Process(Process):
 
    def __init__(self,num):
        Process.__init__(self)
        self.num = num
 
    def run(self):
        time.sleep(2)
        print(self.num)
 
 
def main():
    for i in range(10):
        p = My_Process(i)
        p.start()
 
 
if __name__ == '__main__':
    main()

进程池

from multiprocessing import Pool
import time
 
 
def target(num):
    time.sleep(2)
    print(num)
 
 
def main():
    pool = Pool(3)
    for i in range(3):
        pool.apply_async(target,(i,))
    pool.close()
    pool.join()
    print('Finish!!!')
 
 
if __name__ == '__main__':
    main()

对Pool对象调用join()方法会等待所有子进程执行完毕，调用join()之前必须先调用close()，调用close()之后就不能继续添加新的Process了。
Pool(num)里的num为要添加到里面的进程数。不指定进程数，则默认为CPU核心数量。

进程间相互独立

多进程的每一个进程都有一份变量的拷贝，进程之间的操作互不影响。

import multiprocessing
import time
 
zero = 0
 
def change_zero():
    global zero
    for i in range(3):
        zero = zero + 1
        print(multiprocessing.current_process().name, zero)
 
if __name__ == '__main__':
    p1 = multiprocessing.Process(target = change_zero)
    p2 = multiprocessing.Process(target = change_zero)
    p1.start()
    p2.start()
    p1.join()
    p2.join()
    print(zero)

最后的执行结果：

如果进行文件IO操作，则多进程都会写入同一个文件中。

队列

使用multiprocessing里的Queue可使不同进程访问相同的资源。

from multiprocessing import Process, Queue
def addone(q):
    q.put(1)
def addtwo(q):
    q.put(2)
if __name__ == '__main__':
    q = Queue()
    p1 = Process(target=addone, args = (q, ))
    p2 = Process(target=addtwo, args = (q, ))
    p1.start()
    p2.start()
    p1.join()
    p2.join()
    print(q.get())
    print(q.get())