Starter code for trio demo.

Author: mikeckennedy

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

@@ -7,3 +7,4 @@ aiodns
 cchardet
 requests
 bs4
+colorama

Diff for: src/09-built-on-asyncio/requirements.txt

@@ -0,0 +1,51 @@
+import datetime
+import colorama
+import random
+import asyncio
+
+
+def main():
+    t0 = datetime.datetime.now()
+    print(colorama.Fore.WHITE + "App started.", flush=True)
+
+    loop = asyncio.get_event_loop()
+    data = asyncio.Queue()
+
+    task1 = loop.create_task(generate_data(20, data))
+    task3 = loop.create_task(generate_data(20, data))
+    # task4 = loop.create_task(generate_data(20, data))
+    task2 = loop.create_task(process_data(40, data))
+
+    final_task = asyncio.gather(task1, task2, task3)
+    loop.run_until_complete(final_task)
+
+    dt = datetime.datetime.now() - t0
+    print(colorama.Fore.WHITE + "App exiting, total time: {:,.2f} sec.".format(dt.total_seconds()), flush=True)
+
+
+async def generate_data(num: int, data: asyncio.Queue):
+    for idx in range(1, num + 1):
+        item = idx*idx
+        await data.put((item, datetime.datetime.now()))
+
+        print(colorama.Fore.YELLOW + f" -- generated item {idx}", flush=True)
+        await asyncio.sleep(random.random() + .5)
+
+
+async def process_data(num: int, data: asyncio.Queue):
+    processed = 0
+    while processed < num:
+        item = await data.get()
+
+        processed += 1
+        value = item[0]
+        t = item[1]
+        dt = datetime.datetime.now() - t
+
+        print(colorama.Fore.CYAN +
+              " +++ Processed value {} after {:,.2f} sec.".format(value, dt.total_seconds()), flush=True)
+        await asyncio.sleep(.5)
+
+
+if __name__ == '__main__':
+    main()

Diff for: src/09-built-on-asyncio/the_trio/prod_asyncio.py

@@ -0,0 +1,46 @@
+import datetime
+import colorama
+import random
+import time
+
+
+def main():
+    t0 = datetime.datetime.now()
+    print(colorama.Fore.WHITE + "App started.", flush=True)
+    data = []
+    generate_data(20, data)
+    process_data(20, data)
+
+    dt = datetime.datetime.now() - t0
+    print(colorama.Fore.WHITE + "App exiting, total time: {:,.2f} sec.".format(dt.total_seconds()), flush=True)
+
+
+def generate_data(num: int, data: list):
+    for idx in range(1, num + 1):
+        item = idx*idx
+        data.append((item, datetime.datetime.now()))
+
+        print(colorama.Fore.YELLOW + f" -- generated item {idx}", flush=True)
+        time.sleep(random.random() + .5)
+
+
+def process_data(num: int, data: list):
+    processed = 0
+    while processed < num:
+        item = data.pop(0)
+        if not item:
+            time.sleep(.01)
+            continue
+
+        processed += 1
+        value = item[0]
+        t = item[1]
+        dt = datetime.datetime.now() - t
+
+        print(colorama.Fore.CYAN +
+              " +++ Processed value {} after {:,.2f} sec.".format(value, dt.total_seconds()), flush=True)
+        time.sleep(.5)
+
+
+if __name__ == '__main__':
+    main()