进程间通信

 

#!/usr/bin/env python

# -*- coding=utf-8 -*-

 

import multiprocessing

 

def counsumer(input_q):

    while True:

        item  = input_q.get()

        #处理项目

        print item    #此处替换为有用的工作

        #发出信号通知任务完成

        input_q.task_done()

 

def producer(sequence,output_q):

    for item in sequence:

        #将项目放入队列

        output_q.put(item)

 

#建立进程

if __name__ == '__main__':

    q = multiprocessing.JoinableQueue()#创建可连接的共享进程队列

 

    cons_q = multiprocessing.Process(target=counsumer,args=(q,))

    cons_q.daemon = True

    cons_q.start()

 

    sequence = [1,2,3,4]

    producer(sequence,q)

 

    q.join()

 

    print 'success'