使用Pipe方法通信

Posted 2020-10-11

from multiprocessing import Process,Pipe
import random
import time, os

def proc_send(pipe,urls):
    for url in urls:
        print ‘Process (%s) send: %s‘ % (os.getpid(),url)
        pipe.send(url)
        time.sleep(random.random())

def proc_recv(pipe):
    while True:
        print ‘Process (%s) rev: %s‘ % (os.getpid(),pipe.recv())
        time.sleep(random.random())

if __name__ == ‘__main__‘:
    pipe = Pipe()
    p1 = Process(target=proc_send, args=(pipe[0],[‘url_‘+str(i) for i in range(10)]))
    p2 = Process(target=proc_recv, args=(pipe[1],))
    p1.start()
    p2.start()
    p1.join()
    p2.join()

 Process方法： 

　　“args:”用于传递参数，作用于"target="后跟的函数

　　

Process (5396) send: url_0
Process (3860) rev: url_0
Process (5396) send: url_1
Process (3860) rev: url_1
Process (5396) send: url_2
Process (5396) send: url_3
Process (3860) rev: url_2
Process (5396) send: url_4
Process (5396) send: url_5
Process (3860) rev: url_3
Process (5396) send: url_6
Process (3860) rev: url_4
Process (5396) send: url_7
Process (3860) rev: url_5
Process (3860) rev: url_6
Process (5396) send: url_8
Process (3860) rev: url_7
Process (3860) rev: url_8
Process (5396) send: url_9
Process (3860) rev: url_9

 

The Pipe() function returns a pair of connection objects connected by a pipe which by default is duplex (two-way).

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()

The two connection objects returned by Pipe() represent the two ends of the pipe. Each connection object has send() and recv()methods (among others). Note that data in a pipe may become corrupted if two processes (or threads) try to read from or write to the same end of the pipe at the same time. Of course there is no risk of corruption from processes using different ends of the pipe at the same time.