一.进程间同步
对于一些临界资源,不能使用并发无限消耗,就需要设置专门的临界标示,比如锁或者信号量等
from multiprocessing import Process, Lock import time def f(l, i): l.acquire() try: print('hello world', i) time.sleep(1) finally: l.release() def f2(l, i): l.acquire() try: print('nin hao?', i) time.sleep(1) finally: l.release() if __name__ == '__main__': lock = Lock() for num in range(10): Process(target=f, args=(lock, num)).start() Process(target=f2, args=(lock, num)).start()
二.进程间通信
有时候需要在进程之间交换对象
multiprocessing 支持进程之间的两种通信通道:
(1).队列
Queue 类是一个近似 queue.Queue 的克隆。 例如:
from multiprocessing import Process, Queue def f(q): q.put([42, None, 'hello']) if __name__ == '__main__': q = Queue() p = Process(target=f, args=(q,)) p.start() print(q.get()) # prints "[42, None, 'hello']" p.join()
队列是线程和进程安全的。
(2).管道
Piep 函数返回一个由管道连接的连接对象,默认情况下是双工(双向)。例如:
from multiprocessing import Process, Pipe def f(conn): conn.send([42, None, 'hello']) conn.close() if __name__ == '__main__': parent_conn, child_conn = Pipe() p = Process(target=f, args=(child_conn,)) p.start() print(parent_conn.recv()) # prints "[42, None, 'hello']" p.join()