diff options
author | Victor Stinner <victor.stinner@gmail.com> | 2014-11-19 13:50:34 +0100 |
---|---|---|
committer | Victor Stinner <victor.stinner@gmail.com> | 2014-11-19 13:50:34 +0100 |
commit | 8e73bf4e8917fb7c4ff7b06382f0099171ae4a87 (patch) | |
tree | b25eb3a676cf1a1e31661781e979982582ca2ae4 | |
parent | 45636aa3e53528ab1d377c6df911d1245fbfdccd (diff) | |
download | aioeventlet-8e73bf4e8917fb7c4ff7b06382f0099171ae4a87.tar.gz |
add more manual tests
-rw-r--r-- | manual_tests/date_cb.py | 19 | ||||
-rw-r--r-- | manual_tests/hello_coro.py | 14 | ||||
-rw-r--r-- | manual_tests/later_stop_later.py | 29 | ||||
-rw-r--r-- | manual_tests/soon_stop_soon.py | 33 | ||||
-rw-r--r-- | manual_tests/test_thread.py | 16 |
5 files changed, 111 insertions, 0 deletions
diff --git a/manual_tests/date_cb.py b/manual_tests/date_cb.py new file mode 100644 index 0000000..05cdbcb --- /dev/null +++ b/manual_tests/date_cb.py @@ -0,0 +1,19 @@ +import aiogreen +import datetime + +def display_date(end_time, loop): + print(datetime.datetime.now()) + if (loop.time() + 1.0) < end_time: + loop.call_later(1, display_date, end_time, loop) + else: + loop.stop() + +loop = aiogreen.EventLoop() + +# Schedule the first call to display_date() +end_time = loop.time() + 5.0 +loop.call_soon(display_date, end_time, loop) + +# Blocking call interrupted by loop.stop() +loop.run_forever() +loop.close() diff --git a/manual_tests/hello_coro.py b/manual_tests/hello_coro.py new file mode 100644 index 0000000..5cbe417 --- /dev/null +++ b/manual_tests/hello_coro.py @@ -0,0 +1,14 @@ +import logging; logging.basicConfig(level=logging.DEBUG) +import aiogreen, trollius; trollius.set_event_loop_policy(aiogreen.EventLoopPolicy()) +from trollius import From + +import trollius as asyncio + +def work(): + print("Hello") + yield From(trollius.sleep(1)) + print('World') + +loop = asyncio.get_event_loop() +loop.run_until_complete(work()) +loop.close() diff --git a/manual_tests/later_stop_later.py b/manual_tests/later_stop_later.py new file mode 100644 index 0000000..6c6a1c8 --- /dev/null +++ b/manual_tests/later_stop_later.py @@ -0,0 +1,29 @@ +import logging; logging.basicConfig(level=logging.DEBUG) +import aiogreen, trollius; trollius.set_event_loop_policy(aiogreen.EventLoopPolicy()) +from trollius import From + +import trollius +import eventlet +import time + +def hello(): + print("Hello") + +def world(): + print('World') + loop.stop() + +loop = trollius.get_event_loop() +loop.call_later(0.1, hello) +loop.call_later(0.2, loop.stop) +loop.call_later(0.3, world) +print("run forever") +loop.run_forever() + +print("sleep") +eventlet.sleep(1.0) + +print("run forever") +loop.run_forever() + +loop.close() diff --git a/manual_tests/soon_stop_soon.py b/manual_tests/soon_stop_soon.py new file mode 100644 index 0000000..cede9a1 --- /dev/null +++ b/manual_tests/soon_stop_soon.py @@ -0,0 +1,33 @@ +import logging; logging.basicConfig(level=logging.DEBUG) +import aiogreen, trollius; trollius.set_event_loop_policy(aiogreen.EventLoopPolicy()) +from trollius import From + +import trollius +import time + +def hello(): + print("Hello") + +def stop(): + print("stop") + loop.stop() + +def world(): + print('World') + print("stop") + loop.stop() + +loop = trollius.get_event_loop() +loop.call_soon(hello) +loop.call_soon(stop) +loop.call_soon(world) +print("run forever") +loop.run_forever() + +print("sleep") +time.sleep(1.0) + +print("run forever") +loop.run_forever() + +loop.close() diff --git a/manual_tests/test_thread.py b/manual_tests/test_thread.py new file mode 100644 index 0000000..9aa38d5 --- /dev/null +++ b/manual_tests/test_thread.py @@ -0,0 +1,16 @@ +import logging; logging.basicConfig(level=logging.DEBUG) +import aiogreen +import time +import trollius + +def work(): + print("Hello") + print("loop", trollius.get_event_loop()) + time.sleep(1) + print('World') + +trollius.set_event_loop_policy(aiogreen.EventLoopPolicy()) +loop = trollius.get_event_loop() +loop.run_until_complete(loop.run_in_executor(None, work)) +loop.run_until_complete(loop.run_in_executor(None, work)) +loop.close() |