1.進(jìn)程的創(chuàng)建

import multiprocessing

def func(msg):
    print(msg)
    print('This is a processing')

if __name__ == '__main__':
    p = multiprocessing.Process(target=func,args=('test',))
    p.start()

2.進(jìn)程的并行

import multiprocessing

def func(msg):
    print(msg)
    print('This is a processing')

if __name__ == '__main__':
    p1 = multiprocessing.Process(target=func,args=('test1',))
    p2 = multiprocessing.Process(target=func,args=('test2',))
    p1.start()
    p2.start()
    p1.join()
    p2.join()

3.進(jìn)程鎖的兩種使用方法

import multiprocessing
from datetime import datetime,timedelta

#with用鎖
def func2(lock,f):
    with lock:
        print(datetime.now())

#lock.acquire()用鎖
def func1(lock,f):
    lock.acquire()
    
    print(datetime.now())

    lock.release

if __name__ == '__main__':
    lock = multiprocessing.Lock()
    f = 'file.txt'
    p1 = multiprocessing.Process(target=func2,args=(lock,f))
    p2 = multiprocessing.Process(target=func1,args=(lock,f))
    p1.start()
    p2.start()
    p1.join()
    p2.join()

3.設(shè)置資源的訪問數(shù)量

import multiprocessing
from datetime import datetime,timedelta

#with用鎖
def func2(s,lock,f):
    with s:
        with lock:
            print(func2.__name__ +' ' +datetime.now().strftime('%Y-%m-%d %H-%S-%M'))

#lock.acquire()用所
def func1(lock,f):
    lock.acquire()

    print(func1.__name__ +' ' + datetime.now().strftime('%Y-%m-%d %H-%S-%M'))

    lock.release

if __name__ == '__main__':
    s = multiprocessing.Semaphore(2) # 設(shè)置只能訪問兩次
    for i in range(5):
        lock = multiprocessing.Lock()
        f = 'file.txt'
        p1 = multiprocessing.Process(target=func2,args=(s,lock,f))
        p2 = multiprocessing.Process(target=func1,args=(lock,f))
        p1.start()
        p2.start()
        p1.join()
        p2.join()

4.Processing 隊列設(shè)置

import multiprocessing

def write(q):
    q.put('Hello,World')

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


if __name__ == '__main__':
    q = multiprocessing.Queue()
    qwriter = multiprocessing.Process(target=write,args=(q,))
    qreader = multiprocessing.Process(target=read,args=(q,))
    qwriter.start()
    qreader.start()

5.管道pipe

pipe返回（conn1脓匿，conn2）代表管道的兩端吨艇，可以用[0]袱饭、[1]調(diào)用劈彪；

duplex參數(shù)如果設(shè)為True浇雹，則conn1和conn2都可以收發(fā)壹若；

duplex參數(shù)如果設(shè)為False稿蹲，則conn1負(fù)責(zé)接收扭勉，conn2負(fù)責(zé)發(fā)送。

import multiprocessing

def sender(p):
   p.send("hello world")

def receiver(p):
    print(p.recv())

if __name__ == "__main__":
    p = multiprocessing.Pipe()
    psender=multiprocessing.Process(target=sender,args=(p[0],))
    preceiver = multiprocessing.Process(target=receiver, args=(p[1],))
    psender.start()
    preceiver.start()

6.進(jìn)程之間manager

manager實(shí)現(xiàn)進(jìn)程之間數(shù)據(jù)共享

import multiprocessing

def func(list1,d,i):
    list1[i] = i
    d['a'] = i

if __name__ == "__main__":
    with multiprocessing.Manager() as manager:
        list1 = manager.list(range(5,10))
        d = manager.dict()
        plist = []
        for i in range(5):
            p = multiprocessing.Process(target=func,args=(list1,d,i))
            plist.append(p)
            p.start()
            p.join()
        for i in plist:
            print(i)
        print(d)
        print(list1)