进程相关内容

一、创建进程的两种方式

#方式一：直接创建
from multiprocessing import Process
import time
def f(name):
    time.sleep(1)
    print('hello',name,time.ctime())

if __name__ == '__main__':
    p_list = []
    for i in range(3):
        p = Process(target=f,args=('alex',))    #创建子进程
        p_list.append(p)
        p.start()     #启动子进程
    for p in p_list:
        p.join()
    print('end')

'''方式2：通过类创建'''
from multiprocessing import Process
import time
class MyProcess(Process):
    def __init__(self):
        super(MyProcess, self).__init__()
    def run(self):
        time.sleep(1)
        print('hello',self.name,time.ctime())
if __name__ ==  '__main__':
    p_list = []
    for i in range(3):
        p = MyProcess()
        p_list.append(p)
        p.start()
    for p in p_list:
        p.join()

二、queue实现数据共享

from multiprocessing import Process,Queue

def f(q):
    q.put([5,'hel'])   #往队列里加内容

def f2(q):
    print(q.get())

if __name__ == '__main__':
    q = Queue()    #创建进程队列对象

    p_list = []
    for i in range(3):
        p = Process(target=f,args=(q,))   #创建进程
        p_list.append(p)
    for p in p_list:
        p.start()
    for p in p_list:
        p.join()

    p2_list = []
    for i in range(3):
        p2 = Process(target=f2,args=(q,))
        p2_list.append(p2)
    for p2 in p2_list:
        p2.start()
    for p2 in p_list:
        p2.join()
'''1.实现的功能：通过三个进程往一个队列里存三条内容，然后用另外三个进程从队列取内容并打印
   2.实现的方式：在创建子进程时将主进程中创建的队列对象通过参数传到子进程中'''

三、Pipe实现进程通信

'''通过Pipe对象实现进程通信'''
from multiprocessing import Process,Pipe

def f(conn):
    conn.send('月')
    conn.close()

if __name__ == '__main__':
    parent_conn,child_conn = Pipe()
    p = Process(target=f,args=(child_conn,))   #创建进程
    p.start()
    print(parent_conn.recv())
    p.join()

'''通过Pipe对象实现进程通信，类似于socket通信一收一发'''

四、manager实现数据共享

from multiprocessing import Process,Manager

def f(d,l,n):
    d[n] = '1'
    d['2'] = 2
    d[0.25] = None
    l.append(n)

if __name__ == '__main__':
    with Manager() as manager:
        d = manager.dict()   #用manager创建字典
        l = manager.list()   #用manager创建列表
        p_list = []
        for i in range(10):
            p = Process(target=f,args=(d,l,i))
            p.start()
            p_list.append(p)
        for p in p_list:
            p.join()

        print(d)
        print(l)

'''1.十个进程同时去操作同一字典/列表
   2.用Manager()对象创建的列表/字典可以被多个进程同时使用，实现数据共享'''