Starter code for unsync and trio.

Author: mikeckennedy

src/09-built-on-asyncio/.idea/dictionaries/screencaster.xml

@@ -0,0 +1,9 @@
+unsync
+trio
+trio_asyncio
+
+aiohttp
+aiodns
+cchardet
+requests
+bs4

src/09-built-on-asyncio/.idea/vcs.xml

@@ -0,0 +1,9 @@
+import math
+
+
+def do_math(start=0, num=10):
+    pos = start
+    k_sq = 1000 * 1000
+    while pos < num:
+        pos += 1
+        math.sqrt((pos - k_sq)*(pos - k_sq))

src/09-built-on-asyncio/requirements.txt

@@ -0,0 +1,61 @@
+import datetime
+import math
+import time
+import requests
+
+
+def main():
+    t0 = datetime.datetime.now()
+
+    compute_some()
+    compute_some()
+    compute_some()
+    download_some()
+    download_some()
+    download_some_more()
+    download_some_more()
+    wait_some()
+    wait_some()
+    wait_some()
+    wait_some()
+
+    dt = datetime.datetime.now() - t0
+    print("Synchronous version done in {:,.2f} seconds.".format(dt.total_seconds()))
+
+
+def compute_some():
+    print("Computing...")
+    for _ in range(1, 10_000_000):
+        math.sqrt(25 ** 25 + .01)
+
+
+def download_some():
+    print("Downloading...")
+    url = 'https://talkpython.fm/episodes/show/174/coming-into-python-from-another-industry-part-2'
+    resp = requests.get(url)
+    resp.raise_for_status()
+
+    text = resp.text
+
+    print("Downloaded (more) {:,} characters.".format(len(text)))
+
+
+def download_some_more():
+    print("Downloading more ...")
+    url = 'https://pythonbytes.fm/episodes/show/92/will-your-python-be-compiled'
+    resp = requests.get(url)
+    resp.raise_for_status()
+
+    text = resp.text
+
+    print("Downloaded {:,} characters.".format(len(text)))
+
+
+def wait_some():
+    print("Waiting...")
+    for _ in range(1, 1000):
+        time.sleep(.001)
+
+
+if __name__ == '__main__':
+    main()

src/09-built-on-asyncio/the_unsync/core.py

@@ -0,0 +1,70 @@
+import asyncio
+import datetime
+import math
+
+import aiohttp
+import requests
+
+
+def main():
+    t0 = datetime.datetime.now()
+
+    loop = asyncio.get_event_loop()
+
+    tasks = [
+        loop.create_task(compute_some()),
+        loop.create_task(compute_some()),
+        loop.create_task(compute_some()),
+        loop.create_task(download_some()),
+        loop.create_task(download_some()),
+        loop.create_task(download_some_more()),
+        loop.create_task(download_some_more()),
+        loop.create_task(wait_some()),
+        loop.create_task(wait_some()),
+        loop.create_task(wait_some()),
+        loop.create_task(wait_some()),
+    ]
+
+    loop.run_until_complete(asyncio.gather(*tasks))
+
+    dt = datetime.datetime.now() - t0
+    print("Synchronous version done in {:,.2f} seconds.".format(dt.total_seconds()))
+
+
+async def compute_some():
+    print("Computing...")
+    for _ in range(1, 10_000_000):
+        math.sqrt(25 ** 25 + .01)
+
+
+async def download_some():
+    print("Downloading...")
+    url = 'https://talkpython.fm/episodes/show/174/coming-into-python-from-another-industry-part-2'
+    async with aiohttp.ClientSession(connector=aiohttp.TCPConnector(ssl=False)) as session:
+        async with session.get(url) as resp:
+            resp.raise_for_status()
+
+            text = await resp.text()
+
+    print("Downloaded (more) {:,} characters.".format(len(text)))
+
+
+async def download_some_more():
+    print("Downloading more ...")
+    url = 'https://pythonbytes.fm/episodes/show/92/will-your-python-be-compiled'
+    resp = requests.get(url)
+    resp.raise_for_status()
+
+    text = resp.text
+
+    print("Downloaded {:,} characters.".format(len(text)))
+
+
+async def wait_some():
+    print("Waiting...")
+    for _ in range(1, 1000):
+        await asyncio.sleep(.001)
+
+
+if __name__ == '__main__':
+    main()

src/09-built-on-asyncio/the_unsync/nosync.py

@@ -0,0 +1,70 @@
+import asyncio
+import datetime
+import math
+
+import aiohttp
+import requests
+
+
+def main():
+    t0 = datetime.datetime.now()
+
+    loop = asyncio.get_event_loop()
+
+    tasks = [
+        loop.create_task(compute_some()),
+        loop.create_task(compute_some()),
+        loop.create_task(compute_some()),
+        loop.create_task(download_some()),
+        loop.create_task(download_some()),
+        loop.create_task(download_some_more()),
+        loop.create_task(download_some_more()),
+        loop.create_task(wait_some()),
+        loop.create_task(wait_some()),
+        loop.create_task(wait_some()),
+        loop.create_task(wait_some()),
+    ]
+
+    loop.run_until_complete(asyncio.gather(*tasks))
+
+    dt = datetime.datetime.now() - t0
+    print("Synchronous version done in {:,.2f} seconds.".format(dt.total_seconds()))
+
+
+async def compute_some():
+    print("Computing...")
+    for _ in range(1, 10_000_000):
+        math.sqrt(25 ** 25 + .01)
+
+
+async def download_some():
+    print("Downloading...")
+    url = 'https://talkpython.fm/episodes/show/174/coming-into-python-from-another-industry-part-2'
+    async with aiohttp.ClientSession(connector=aiohttp.TCPConnector(ssl=False)) as session:
+        async with session.get(url) as resp:
+            resp.raise_for_status()
+
+            text = await resp.text()
+
+    print("Downloaded (more) {:,} characters.".format(len(text)))
+
+
+async def download_some_more():
+    print("Downloading more ...")
+    url = 'https://pythonbytes.fm/episodes/show/92/will-your-python-be-compiled'
+    resp = requests.get(url)
+    resp.raise_for_status()
+
+    text = resp.text
+
+    print("Downloaded {:,} characters.".format(len(text)))
+
+
+async def wait_some():
+    print("Waiting...")
+    for _ in range(1, 1000):
+        await asyncio.sleep(.001)
+
+
+if __name__ == '__main__':
+    main()