多進程multiprocessing

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())
    print(‘\n‘)

def f(name):
    print(‘\033[31;1mfunction f\033[0m‘)
    print(‘hello‘
 
,name)

if __name__ == ‘__main__‘:
    info(‘\033[32;1mmain process line\033[0m‘)
    p=Process(target=f,args=(‘q1ang‘,))
    p.start()
    # p.join()

>>>

main process line
module name: __main__
parent process: 8044
process id: 11048


function f
hello q1ang

兩進程間的通訊

不同進程間內存是不共享的，要想實現兩個進程間的數據交換，可以用以下方法：

1.進程Queues

def a(q):
    q.put(‘hehe‘)


if __name__==‘__main__‘:
    q=Queue()
    p=Process(target=a,args=(q,))
    p.start()
    print(q.get())
    p.join()

2.Pipe

from multiprocessing import Process,Pipe

def a(conn):
    conn.send(‘hehe‘)
    conn.close()

if __name__ == ‘__main__‘:
    parent_conn,child_conn
 
=Pipe()
    p=Process(target=a,args=(child_conn,))
    p.start()
    print(parent_conn.recv())
    p.join()

3.Managers

from multiprocessing import Process,Manager

def a(d,l):
    d[1]=‘1‘
    d[‘2‘]=2
    d[3]=None
    l.append(1)
    print(l)

if __name__ == ‘__main__‘:
    with Manager() as manager:
        d=manager.dict()
        l=manager.list(range(5))

        p_list=[]
        for i in range(10):
            p=Process(target=a,args=(d,l))
            p.start()
            p_list.append(p)
        for res in p_list:
            res.join()

        print(d)
        print(l)

進程同步：主要功能是屏幕鎖

from multiprocessing import Process,Lock

def f(l,i):
    l.acquire()
    try:
        print(‘hello world‘,i)
    finally:
        l.release()

if __name__ == ‘__main__‘:
    lock=Lock()

    for num in range(10):
        Process(target=f,args=(lock,num)).start()

進程池

進程池內部維護一個進程序列，當使用時，則去進程池中獲取一個進程，如果進程池序列中沒有可供使用的進進程，那麽程序就會等待，直到進程池中有可用進程為止。

apply_async(並行)
apply(串行)

from multiprocessing import Pool
import time,os

def Foo(i):
    time.sleep(1)
    print(i)
    return i

def Bar(arg):
    print(‘-->exec done:‘, arg,os.getpid())

if __name__ == ‘__main__‘:
    pool = Pool(5) #允許進程池同時放入五個進程
    print(os.getpid())
    for i in range(10):
        #apply_async(並行)
        #apply(串行)
        # pool.apply_async(func=Foo, args=(i,), callback=Bar)#callback回調
        pool.apply(func=Foo, args=(i,))
        print(‘end‘)
    pool.close()
    pool.join()  # 進程池中進程執行完畢後再關閉，如果註釋，那麽程序直接關閉。

【進程與線程】多進程