python 协程 python 怎样引入协程和原理分析

def get_url(url):
 html = get_html(url) # 此处网络下载IO操作比较耗时，希望切换到另一个函数去执行
 infos = parse_html(html)
# 下载url中的html
def get_html(url):
 pass
# 解析网页
def parse_html(html):
 pass

def gen_func():
 html = yield 'http://www.baidu.com' # yield 前面加=号就实现了1：可以产出值2：可以接受调用者传过来的值
 print(html)
 yield 2
 yield 3
 return 'bobby'
if __name__ == '__main__':
 gen = gen_func()
 url = next(gen)
 print(url)
 html = 'bobby'
 gen.send(html) # send方法既可以将值传递进生成器内部，又可以重新启动生成器执行到下一yield位置。

打印结果：
http://www.baidu.com
bobby

def gen_func():
 yield 'http://www.baidu.com' # yield 前面加=号就实现了1：可以产出值2：可以接受调用者传过来的值
 yield 2
 yield 3
 return 'bobby'
if __name__ == '__main__':
 gen = gen_func()
 url = next(gen)
 gen.close()
 next(gen)

输出结果：
StopIteration

def gen_func():
 try:
  yield 'http://www.baidu.com' 
 except GeneratorExit:
  pass
 yield 2
 yield 3
 return 'bobby'
if __name__ == '__main__':
 gen = gen_func()
 print(next(gen))
 gen.close()
 next(gen)

输出结果：
RuntimeError: generator ignored GeneratorExit

def gen_func():
 yield 'http://www.baidu.com' # yield 前面加=号就实现了1：可以产出值2：可以接受调用者传过来的值
 yield 2
 yield 3
 return 'bobby'
if __name__ == '__main__':
 gen = gen_func()
 print(next(gen))
 gen.throw(Exception, 'Download Error')

输出结果：
 Download Error

from itertools import chain
my_list = [1,2,3]
my_dict = {'frank':'yangchao', 'ailsa':'liuliu'}
for value in chain(my_list, my_dict, range(5,10)): chain()方法可以传入多个可迭代对象，然后分别遍历之。
 print(value)

打印结果：
1
2
3
frank
ailsa
5
6
7
8
9

my_list = [1,2,3]
my_dict = {'frank':'yangchao', 'ailsa':'liuliu'}
def chain(*args, **kwargs):
 for itemrable in args:
  yield from itemrable
for value in chain(my_list, my_dict, range(5,10)):
 print(value)

def gen():
 yield 1

def g1(gen):
 yield from gen

def main():
 g = g1(gen)
 g.send(None)

final_result = {}
def sales_sum(pro_name):
 total = 0
 nums = []
 while True:
  x = yield
  print(pro_name+'销量', x)
  if not x:
   break
  total += x
  nums.append(x)
 return total, nums #程序运行到return的时候，会将return的返回值返回给委托方，即middle中的final_result[key]
def middle(key):
 while True: #相当于不停监听sales_sum是否有返回数据，（本例中有三次返回）
  final_result[key] = yield from sales_sum(key)
  print(key +'销量统计完成！！')
def main():
 data_sets = {
  '面膜':[1200, 1500, 3000],
  '手机':[88, 100, 98, 108],
  '衣服':[280, 560,778,70],
 }

 for key, data_set in data_sets.items():
  print('start key', key)
  m = middle(key)
  m.send(None) # 预激生成器
  for value in data_set:
   m.send(value)
  m.send(None)# 发送一个None使sales_sum中的x值为None退出while循环
 print(final_result)
if __name__ == '__main__':
 main()

结果：
start key 面膜
面膜销量 1200
面膜销量 1500
面膜销量 3000
面膜销量 None
面膜销量统计完成！！
start key 手机
手机销量 88
手机销量 100
手机销量 98
手机销量 108
手机销量 None
手机销量统计完成！！
start key 衣服
衣服销量 280
衣服销量 560
衣服销量 778
衣服销量 70
衣服销量 None
衣服销量统计完成！！
{'面膜': (5700, [1200, 1500, 3000]), '手机': (394, [88, 100, 98, 108]), '衣服': (1688, [280, 560, 778, 70])}

def sales_sum(pro_name):
 total = 0
 nums = []
 while True:
  x = yield
  print(pro_name+'销量', x)
  if not x:
   break
  total += 1
  nums.append(x)
 return total, nums

if __name__ == '__main__':
 my_gen = sales_sum('面膜')
 my_gen.send(None)
 my_gen.send(1200)
 my_gen.send(1500)
 my_gen.send(3000)
 my_gen.send(None)

输出结果：
面膜销量 1200
面膜销量 1500
面膜销量 3000
面膜销量 None
Traceback (most recent call last):
 File "D:/MyCode/Cuiqingcai/Flask/test01.py", line 56, in <module>
 my_gen.send(None)
StopIteration: (3, [1200, 1500, 3000])