-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathasync_programming_in_python_example.py
54 lines (38 loc) · 1.45 KB
/
async_programming_in_python_example.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
print("======gevent")
import gevent.monkey
from urllib.request import urlopen
gevent.monkey.patch_all()
urls = ['http://www.google.com', 'http://www.yandex.ru', 'http://www.python.org']
def print_head(url):
print('Starting {}'.format(url))
data = urlopen(url).read()
print('{}: {} bytes: {}'.format(url, len(data), data[:15]))
jobs = [gevent.spawn(print_head, _url) for _url in urls]
gevent.wait(jobs)
print("======asyncio")
import asyncio
import aiohttp
urls = ['http://www.google.com', 'http://www.yandex.ru', 'http://www.python.org']
@asyncio.coroutine
def call_url(url):
print('Starting {}'.format(url))
response = yield from aiohttp.ClientSession().get(url)
data = yield from response.text()
print('{}: {} bytes: {}'.format(url, len(data), data[:15]))
return data
futures = [call_url(url) for url in urls]
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(futures))
print("======Async и Await")
import asyncio
import aiohttp
urls = ['http://www.google.com', 'http://www.yandex.ru', 'http://www.python.org']
async def call_url(url):
print('Starting {}'.format(url))
response = await aiohttp.ClientSession().get(url)
data = await response.text()
print('{}: {} bytes: {}'.format(url, len(data), data[0:15]))
return data
futures = [call_url(url) for url in urls]
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(futures))