blob: d848228df2b7a23c0cba70205fef0397b61cdb9d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
import asyncio
import time
import sys
import os
sys.path.append(os.path.expanduser('~/nemesis/'))
from nemesis.causal_event_loop import causal_loop_factory
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.sleep(duration)
async def main():
total_duration = 90
sleep_durations = [1.0, 0.7, 0.7, 0.4]
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)
|
