axiaoxin · December 21, 2017 02:49 · axiaoxin · Dec 21, 2017 · axiaoxin · Dec 21, 2017
diff --git a/yield协程 b/yield协程
 # -*- coding: utf-8 -*-
 import random

 def get_data():
    """返回0到9之间的3个随机数，模拟异步操作"""
    return random.sample(range(10), 3)

 def consume():
    """显示每次传入的整数列表的动态平均值"""
    running_sum = 0
    data_items_seen = 0

    while True:
        print('Waiting to consume')
        data = yield
        data_items_seen += len(data)
        running_sum += sum(data)
        print('Consumed, the running average is {}'.format(running_sum / float(data_items_seen)))

 def produce(consumer):
    """产生序列集合，传递给消费函数（consumer）"""
    while True:
        data = get_data()
        print('Produced {}'.format(data))
        consumer.send(data)
        yield

 if __name__ == '__main__':
    consumer = consume()
    print 'send None'
    consumer.send(None)
    producer = produce(consumer)

    for _ in range(10):
        print('Producing...')
        next(producer)
	# -- coding: utf-8 --
	import random

	def get_data():
	"""返回0到9之间的3个随机数，模拟异步操作"""
	return random.sample(range(10), 3)

	def consume():
	"""显示每次传入的整数列表的动态平均值"""
	running_sum = 0
	data_items_seen = 0

	while True:
	print('Waiting to consume')
	data = yield
	data_items_seen += len(data)
	running_sum += sum(data)
	print('Consumed, the running average is {}'.format(running_sum / float(data_items_seen)))

	def produce(consumer):
	"""产生序列集合，传递给消费函数（consumer）"""
	while True:
	data = get_data()
	print('Produced {}'.format(data))
	consumer.send(data)
	yield

	if __name__ == '__main__':
	consumer = consume()
	print 'send None'
	consumer.send(None)
	producer = produce(consumer)

	for _ in range(10):
	print('Producing...')
	next(producer)
No results found