feijiliu
diff --git a/Collapse file
‎samples/async/async_hello.py‎
Copy file name to clipboard
+6-4Lines changed: 6 additions & 4 deletions b/Collapse file
‎samples/async/async_hello.py‎
Copy file name to clipboard
+6-4Lines changed: 6 additions & 4 deletions
diff --git a/Collapse file
‎samples/async/async_wget.py‎
Copy file name to clipboardExpand all lines: samples/async/async_wget.py
+2-6Lines changed: 2 additions & 6 deletions b/Collapse file
‎samples/async/async_wget.py‎
Copy file name to clipboardExpand all lines: samples/async/async_wget.py
+2-6Lines changed: 2 additions & 6 deletions
@@ -1,14 +1,16 @@
 #!/usr/bin/env python3
 # -*- coding: utf-8 -*-
 
+import threading
 import asyncio
 
 @asyncio.coroutine
 def hello():
-    print("Hello world!")
-    r = yield from asyncio.sleep(1)
-    print("Hello again!")
+    print('Hello world! (%s)' % threading.currentThread())
+    yield from asyncio.sleep(1)
+    print('Hello again! (%s)' % threading.currentThread())
 
 loop = asyncio.get_event_loop()
-loop.run_until_complete(hello())
+tasks = [hello(), hello()]
+loop.run_until_complete(asyncio.wait(tasks))
 loop.close()
@@ -1,13 +1,11 @@
 #!/usr/bin/env python3
 # -*- coding: utf-8 -*-
 
-import threading
 import asyncio
 
 @asyncio.coroutine
 def wget(host):
     print('wget %s...' % host)
-    print('current thread: %s' % threading.current_thread())
     connect = asyncio.open_connection(host, 80)
     reader, writer = yield from connect
     header = 'GET / HTTP/1.0\r\nHost: %s\r\n\r\n' % host
@@ -22,8 +20,6 @@ def wget(host):
     writer.close()
 
 loop = asyncio.get_event_loop()
-tasks = [asyncio.async(wget(host)) for host in ['www.sina.com.cn', 'www.sohu.com', 'www.163.com']]
-for task in tasks:
-    loop.run_until_complete(task)
+tasks = [wget(host) for host in ['www.sina.com.cn', 'www.sohu.com', 'www.163.com']]
+loop.run_until_complete(asyncio.wait(tasks))
 loop.close()
-print('main thread: %s' % threading.current_thread())