Merge pull request #53 from eldaduzman/TASK/#49

add concurrent code testing

Author: eldaduzman

.github/workflows/tox-action.yaml

@@ -27,3 +27,10 @@ jobs:
 
       - name: test with tox
         run: tox
+
+      - name: Test Reporter
+        uses: actions/upload-artifact@v1
+        with:
+          name: rf-tests-report-${{ matrix.os }}-${{ matrix.python_version }}-${{ matrix.rbf_version }}
+          path: ./TEST_GeventLibrary.xml
+

atests/pylibs/__init__.py

@@ -0,0 +1,34 @@
+import asyncio
+import time
+from gevent import joinall, spawn, pool
+from concurrent.futures import ThreadPoolExecutor, ProcessPoolExecutor
+
+
+def sleep_threading(iterations: int, seconds: int):
+    with ThreadPoolExecutor(10) as t:
+        futures = [t.submit(time.sleep, seconds) for _ in range(iterations)]
+
+        for f in futures:
+            f.result()
+
+
+def sleep_processing(iterations: int, seconds: int):
+    with ProcessPoolExecutor(10) as t:
+        futures = [t.submit(time.sleep, seconds) for _ in range(iterations)]
+
+        for f in futures:
+            f.result()
+
+
+def sleep_gevent_coros(iterations: int, seconds: int):
+    jobs = [spawn(time.sleep, seconds) for _ in range(iterations)]
+    _ = joinall(jobs, timeout=30)
+
+
+def sleep_asyncio(iterations: int, seconds: int):
+    async def do_something():
+        jobs = [asyncio.sleep(seconds) for _ in range(iterations)]
+        _ = await asyncio.gather(*jobs)
+
+    loop = asyncio.get_event_loop()
+    loop.run_until_complete(do_something())

atests/simple-test.robot

@@ -6,18 +6,20 @@ Library             Collections
 Library             String
 Library             GeventLibrary
 Library             RequestsLibrary
+Library             ./pylibs/__init__.py
+
+Test Teardown       Clear All Bundles
 
-Suite Teardown    Clear All Bundles
 
 *** Test Cases ***
 Test1
     [Documentation]    Simple test flow with gevent greenlets
     Log    Hello World
     Create Gevent Bundle    alias=alias1
-    Sleep    10s    alias=alias1    # synchronous keyword
+    Sleep    5s    alias=alias1    # synchronous keyword
     Add Coroutine    Sleep Wrapper    alias=alias1
-    Add Coroutine    Sleep    time_=20s    alias=alias1
-    Add Coroutine    Sleep    10s    alias=alias1
+    Add Coroutine    Sleep    time_=10s    alias=alias1
+    Add Coroutine    Sleep    5s    alias=alias1
     Add Coroutine    GET    https://jsonplaceholder.typicode.com/posts/1    alias=alias1
     Add Coroutine    Convert To Lower Case    UPPER
     Add Coroutine    Convert To Integer    1
@@ -39,6 +41,37 @@ Test2
     ${values}    Run Coroutines    alias=alias2    gevent_pool_size=40
     Log Many    @{values}
 
+Test3
+    [Documentation]    Testing a concurrent keyword with threads
+    Create Gevent Bundle    alias=alias1
+    Add Coroutine    Sleep Threading    2    7    alias=alias1
+    Add Coroutine    Sleep    5s    alias=alias1
+    ${values}    Run Coroutines    alias=alias1
+    Log Many    @{values}
+
+Test4
+    [Documentation]    Testing a concurrent keyword with processes
+    Create Gevent Bundle    alias=alias1
+    Add Coroutine    Sleep Processing    2    7    alias=alias1
+    Add Coroutine    Sleep    5s    alias=alias1
+    ${values}    Run Coroutines    alias=alias1
+    Log Many    @{values}
+
+Test5
+    [Documentation]    Testing a concurrent keyword with gevent
+    Create Gevent Bundle    alias=alias1
+    Add Coroutine    Sleep Gevent Coros    3    7    alias=alias1
+    Add Coroutine    Sleep    5s    alias=alias1
+    ${values}    Run Coroutines    alias=alias1
+    Log Many    @{values}
+Test6
+    [Documentation]    Testing a concurrent keyword with asyncio
+    Create Gevent Bundle    alias=alias1
+    Add Coroutine    Sleep Asyncio    3    7    alias=alias1
+    Add Coroutine    Sleep    5s    alias=alias1
+    ${values}    Run Coroutines    alias=alias1
+    Log Many    @{values}
+
 
 *** Keywords ***
 Wrapper1

docs/GeventLibrary.html

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "robotframework-gevent"
-version = "0.3.0"
+version = "0.4.0"
 description = "Run keywords asynchronously with the power of gevent"
 authors = ["Eldad Uzman <[email protected]>"]
 license = "MIT"

pyproject.toml

@@ -54,6 +54,15 @@ class GeventLibrary(DynamicCore):
     |     ${values}               Run Coroutines    alias=alias1
     |     Log Many                @{values}
 
+    == Calling concurrent keywords ==
+    === Multiprocessing ===
+    Multiprocessing containing code will not result in error, but waiting for process to end is blocking and the event loop will be hanging
+    === Multithreading ===
+    Multithreading containing code will not result in error, but waiting for process to end is blocking and the event loop will be hanging
+    === gevent ===
+    gevent containing code will work properly in a bundle and will be concurrent to the other coroutines.
+    === asyncio ===
+    asyncio containing code will work properly in a bundle and will be concurrent to the other coroutines.
     """
 
     libraries: List[Any] = [GeventKeywords()]

src/GeventLibrary/gevent_library.py

@@ -15,4 +15,4 @@ commands =
     poetry install -v
     poetry run coverage run -m unittest discover
     coverage report
-    robot atests
+    robot -x TEST_GeventLibrary.xml atests