Async/Await examples (#9)

* add

* pytest verbosity

Author: cosmicboy79

.github/workflows/python-app.yml

@@ -36,4 +36,4 @@ jobs:
         flake8 . --count --exit-zero --max-complexity=10 --max-line-length=127 --statistics
     - name: Test with pytest
       run: |
-        pytest
+        pytest -vv

src/asynchronous/__init__.py

@@ -0,0 +1,15 @@
+"""
+Source: https://www.geeksforgeeks.org/python/await-in-python/
+"""
+import asyncio
+from asynchronous.runner.task.myasynctask import custom_async_task
+from asynchronous.runner.operation.myoperations import first_operation, second_operation
+
+# this coroutine runs both runner concurrently with asyncio.gather()
+async def running_concurrently():
+    await asyncio.gather(custom_async_task(first_operation, 3),
+                         custom_async_task(second_operation, 2))
+
+# starts the event loop, running and waiting for both runner to complete
+def main():
+    asyncio.run(running_concurrently())

src/asynchronous/runner/__init__.py

@@ -0,0 +1,9 @@
+"""
+Definition of two simple operations.
+"""
+
+def first_operation():
+    print("First operation")
+
+def second_operation():
+    print("Second operation")

src/asynchronous/runner/concurrent.py

@@ -0,0 +1,15 @@
+"""
+Source: https://www.geeksforgeeks.org/python/await-in-python/
+"""
+import asyncio
+from asynchronous.runner.task.myasynctask import custom_async_task
+from asynchronous.runner.operation.myoperations import first_operation, second_operation
+
+# runs two runner sequentially, waiting for one to finish before starting the next
+async def running_sequentially():
+    await custom_async_task(first_operation, 3)
+    await custom_async_task(second_operation, 2)
+
+# executes both runner, totaling around 5 seconds of runtime
+def main():
+    asyncio.run(running_sequentially())

src/asynchronous/runner/operation/__init__.py

@@ -0,0 +1,12 @@
+import asyncio
+
+async def custom_async_task(func, sleep_time):
+    """
+    Custom asynchronous task (coroutine)
+    :param func: operation to execute
+    :param sleep_time: sleep time
+    """
+    print(f"Execution of {func.__name__} started")
+    func()
+    await asyncio.sleep(sleep_time)
+    print(f"Execution of {func.__name__} completed")