summaryrefslogtreecommitdiff
path: root/t/block_shell_longtime.py
diff options
context:
space:
mode:
Diffstat (limited to 't/block_shell_longtime.py')
-rw-r--r--t/block_shell_longtime.py30
1 files changed, 30 insertions, 0 deletions
diff --git a/t/block_shell_longtime.py b/t/block_shell_longtime.py
new file mode 100644
index 0000000..8d31dd8
--- /dev/null
+++ b/t/block_shell_longtime.py
@@ -0,0 +1,30 @@
+import asyncio
+import sys
+import os
+sys.path.append(os.path.expanduser('~/nemesis/'))
+from nemesis.causal_event_loop import causal_loop_factory
+import time
+
+
+async def burn_cpu(sec):
+ t0 = time.perf_counter()
+ elapsed = 0
+ while (elapsed < sec):
+ for _ in range(1000):
+ pass
+ elapsed = time.perf_counter() - t0
+
+async def sleep_task(duration):
+ await asyncio.create_subprocess_shell(f'sleep {duration}')
+
+async def main():
+ total_duration = 90
+ sleep_durations = [1.0, 0.4, 0.7, 0.7]
+
+ for _ in range(total_duration):
+ tasks = [asyncio.create_task(sleep_task(duration)) for duration in sleep_durations]
+ burn_task = asyncio.create_task(burn_cpu(1))
+
+ await asyncio.gather(burn_task, *tasks)
+
+asyncio.run(main(), loop_factory=causal_loop_factory)