updated some async examples

Author: PythonCHB

source/examples/async/async_executor.py

@@ -26,11 +26,12 @@ async def slow_task():
         # This will block for 2-10 seconds!
         # result = slow_function(random.random() * 8 + 2)
         # uncomment to put it on a different thread:
-        result = await loop.run_in_executor(None,
-                                            slow_function,
-                                            random.random() * 8 + 2)
+        result = slow_function(random.random() * 8 + 2)
+        #result = await loop.run_in_executor(None,
+        #                                    slow_function,
+        #                                    random.random() * 8 + 2)
         print("slow function done: result", result)
-        #await asyncio.sleep(0.0)  # to release the loop
+        await asyncio.sleep(0.0)  # to release the loop
 
 
 def slow_function(duration):

source/examples/async/async_timer.py

@@ -41,6 +41,8 @@ def shutdown():
 # or add tasks to the loop like this:
 loop.create_task(display_date(3))
 loop.create_task(display_date(4))
+for i in range(5, 20):
+    loop.create_task(display_date(i))
 
 # this will shut the event loop down in 15 seconds
 loop.call_later(15, shutdown)

source/examples/async/gather.py

@@ -11,18 +11,18 @@
 
 import asyncio
 
+
 async def factorial(name, number):
     f = 1
-    for i in range(2, number+1):
+    for i in range(2, number + 1):
         print("Task %s: Compute factorial(%s)..." % (name, i))
-        await asyncio.sleep(1)
+        await asyncio.sleep(1)  # to simulate a longer process...
         f *= i
     print("Task %s: factorial(%s) = %s" % (name, number, f))
 
 loop = asyncio.get_event_loop()
-loop.run_until_complete(asyncio.gather(
-    factorial("A", 2),
-    factorial("B", 3),
-    factorial("C", 4),
-))
+loop.run_until_complete(asyncio.gather(factorial("A", 2),
+                                       factorial("B", 3),
+                                       factorial("C", 4),
+                                       ))
 loop.close()

source/examples/async/get_news_sync.py

@@ -24,7 +24,7 @@
 
 def get_sources():
     """
-    get all the english language sources of news
+    Get all the english language sources of news
 
     'https://newsapi.org/v1/sources?language=en'
     """
@@ -33,6 +33,8 @@ def get_sources():
     resp = requests.get(url, params=params)
     data = resp.json()
     sources = [src['id'].strip() for src in data['sources']]
+    print("all the sources")
+    print(sources)
     return sources
 
 

source/examples/async/task_loop.py

@@ -0,0 +1,20 @@
+#!/usr/bin/env python3
+
+"""
+Example code for making the very simplest event loop possible
+
+Inspired by Brett Cannon's "How the heck does async/await work in Python 3.5?":
+
+https://snarky.ca/how-the-heck-does-async-await-work-in-python-3-5
+
+and André Caron's "A tale of event loops":
+
+https://github.com/AndreLouisCaron/a-tale-of-event-loops
+
+I'm calling this a "task loop" rather than an event loop, because it really is
+only designed to run a bunch of tasks asynchronously, wohtout the other
+machinery required to support proper events -- like a way to generate a new
+event, for instance.
+"""
+
+

source/examples/async/ultra_simple.py

@@ -10,7 +10,7 @@
 async def say_lots(num):
     for i in range(num):
         print(f'This was run by the loop ({i}) :')
-        await asyncio.sleep(0.2)
+        await asyncio.sleep(1.0)
 
 # getting the event loop
 loop = asyncio.get_event_loop()

source/examples/threading-multiprocessing/threading/integrate_main.py

@@ -39,7 +39,7 @@ def worker(*args):
     parser.add_argument('a', nargs='?', type=float, default=0.0)
     parser.add_argument('b', nargs='?', type=float, default=10.0)
     parser.add_argument('N', nargs='?', type=int, default=10**7)
-    parser.add_argument('thread_count', nargs='?', type=int, default=2)
+    parser.add_argument('thread_count', nargs='?', type=int, default=4)
 
     args = parser.parse_args()
     a = args.a