摘自 http://xiaorui.cc/2014/09/08/python-multiprocessing%E8%BF%9B%E7%A8%8B%E9%80%9A%E4%BF%A1%E7%9A%84pipe%E5%92%8Cqueue%E6%96%B9%E5%BC%8F/

multiprocessing_01.py

#coding=utf-8
import multiprocessing
import time

def proc1(pipe):
    while True:
        for i in range(10000):
            print 'send %s' % i
            pipe.send(i)
            time.sleep(1)

def proc2(pipe):
    while True:
        print 'proc2 recv', pipe.recv()
        time.sleep(1)

def proc3(pipe):
    while True:
        print 'proc3 recv', pipe().recv()
        time.sleep(1)

if __name__ == '__main__':
    pipe = multiprocessing.Pipe()
    print pipe

    p1 = multiprocessing.Process(target=proc1, args=(pipe[0],))
    p2 = multiprocessing.Process(target=proc2, args=(pipe[1],))

    p1.start()
    p2.start()
    p1.join()
    p2.join()