add python_coroutine.py

Author: xianhu

README.md

@@ -1,7 +1,7 @@
 # LearnPython
 以撸代码的形式学习Python, 具体说明在[知乎专栏-撸代码,学知识](https://zhuanlan.zhihu.com/pythoner)
 
-===============================================================================
+===================================================================================================
 ### python_base.py: 千行代码入门Python
 
 ### python_visual.py: 15张图入门Matplotlib
@@ -25,6 +25,8 @@
 ### python_datetime.py: 你真的了解Python中的日期时间处理吗？
 
 ### python_metaclass.py: Python进阶: 一步步理解Python中的元类metaclass
-===============================================================================
+
+### python_coroutine.py: Python进阶：理解Python中的异步IO和协程(Coroutine), 并应用在爬虫中
+===================================================================================================
 
 ### 您可以fork该项目,并在修改后提交Pull request

python_coroutine.py

@@ -0,0 +1,77 @@
+# _*_ coding: utf-8 _*_
+
+"""
+python_coroutine.py by xianhu
+"""
+
+import asyncio
+import aiohttp
+import threading
+
+
+# 生产者、消费者例子
+def consumer():         # 定义消费者，由于有yeild关键词，此消费者为一个生成器
+    print("[Consumer] Init Consumer ......")
+    r = "init ok"       # 初始化返回结果，并在启动消费者时，返回给生产者
+    while True:
+        n = yield r     # 消费者通过yield关键词接收生产者产生的消息，同时返回结果给生产者
+        print("[Consumer] conusme n = %s, r = %s" % (n, r))
+        r = "consume %s OK" % n     # 消费者消费结果，下个循环返回给生产者
+
+
+def produce(c):         # 定义生产者，此时的 c 为一个生成器
+    print("[Producer] Init Producer ......")
+    r = c.send(None)    # 启动消费者生成器，同时第一次接收返回结果
+    print("[Producer] Start Consumer, return %s" % r)
+    n = 0
+    while n < 5:
+        n += 1
+        print("[Producer] While, Producing %s ......" % n)
+        r = c.send(n)   # 向消费者发送消息，同时准备接收结果。此时会切换到消费者执行
+        print("[Producer] Consumer return: %s" % r)
+    c.close()           # 关闭消费者生成器
+    print("[Producer] Close Producer ......")
+
+# produce(consumer())
+
+
+# 异步IO例子：适配Python3.4，使用asyncio库
+@asyncio.coroutine
+def hello(index):                   # 通过装饰器asyncio.coroutine定义协程
+    print('Hello world! index=%s, thread=%s' % (index, threading.currentThread()))
+    yield from asyncio.sleep(1)     # 模拟IO任务
+    print('Hello again! index=%s, thread=%s' % (index, threading.currentThread()))@asyncio.coroutine
+
+loop = asyncio.get_event_loop()     # 得到一个事件循环模型
+tasks = [hello(1), hello(2)]        # 初始化任务列表
+loop.run_until_complete(asyncio.wait(tasks))    # 执行任务
+loop.close()                        # 关闭事件循环列表
+
+
+# 异步IO例子：适配Python3.5，使用async和await关键字
+async def hello1(index):            # 通过关键字async定义协程
+    print('Hello world! index=%s, thread=%s' % (index, threading.currentThread()))
+    await asyncio.sleep(1)          # 模拟IO任务
+    print('Hello again! index=%s, thread=%s' % (index, threading.currentThread()))
+
+loop = asyncio.get_event_loop()     # 得到一个事件循环模型
+tasks = [hello1(1), hello1(2)]      # 初始化任务列表
+loop.run_until_complete(asyncio.wait(tasks))    # 执行任务
+loop.close()                        # 关闭事件循环列表
+
+
+# aiohttp 实例
+async def get(url):
+    async with aiohttp.ClientSession() as session:
+        async with session.get(url) as resp:
+            print(url, resp.status)
+            print(url, await resp.text())
+
+loop = asyncio.get_event_loop()     # 得到一个事件循环模型
+tasks = [                           # 初始化任务列表
+    get("http://zhushou.360.cn/detail/index/soft_id/3283370"),
+    get("http://zhushou.360.cn/detail/index/soft_id/3264775"),
+    get("http://zhushou.360.cn/detail/index/soft_id/705490")
+]
+loop.run_until_complete(asyncio.wait(tasks))    # 执行任务
+loop.close()                        # 关闭事件循环列表