python-producer-consumer

python-producer-consumer.py

import sys

def producer():

    while True:
        line = sys.stdin.readline()
        yield line

def consumer(p):
    line = p.next()
    while True:
        print "INPUT:",line,
        line = p.send('')


p = producer()
consumer(p)