iframe-proxy | Sunbelt Computer Software

40 lines (32 loc) · 719 Bytes

#!/usr/bin/env python

# -*- encoding: utf-8 -*-

"""

Topic: 进程间使用管道通信

Desc :

"""

import multiprocessing

__author__ = 'Xiong Neng'

def consumer(pipe):

outp, inp = pipe

inp.close()

while True:

try:

item = outp.recv()

except EOFError:

break

print(item)

print('comsumer done')

def producer(seq, inp):

for item in seq:

inp.send(item)

def demo():

(outp, inp) = multiprocessing.Pipe()

consp = multiprocessing.Process(target=consumer, args=((outp, inp), ))

consp.start()

outp.close()

seq = [1, 3, 4, 5]

producer(seq, inp)

inp.close()

consp.join()

if __name__ == '__main__':

demo()

Sunbelt Computer Software