From 1c8b8d2a5faefdf73ec9fccaf24ebbe826f21b97 Mon Sep 17 00:00:00 2001 From: VG Date: Fri, 8 Apr 2016 00:29:35 +0200 Subject: Auto-commit on 807fe7afb37fe2cfcf15c9457d04f64fa11b7511 --- tests/wqueue2.py | 21 ++++++--------------- 1 file changed, 6 insertions(+), 15 deletions(-) diff --git a/tests/wqueue2.py b/tests/wqueue2.py index 5340d0f..4c2cd4c 100755 --- a/tests/wqueue2.py +++ b/tests/wqueue2.py @@ -15,11 +15,10 @@ u8open = functools.partial(open, encoding='utf8') class PersistentQueue3: - def __init__(self, filename=None, loop=None): + def __init__(self, filename=None): self.queue = collections.deque() self.current_job = collections.deque() - self.event = asyncio.Event(loop=loop) - self.loop = loop + self.event = asyncio.Event() self.filename = filename def push_job(self, item): @@ -98,28 +97,20 @@ async def manage_client(reader, writer): print('end of manage_client') -async def manage_jobs(): +async def jobs_runner(): jobs = PersistentQueue3(filename='queue.txt') queue = [] while True: job = await jobs.get_job() - do_the_job(job=job) - async with open('queue.txt') as f: - line = await next(f) - if not line: - # schedule new job - print('executing next scheduled job') - -def read_next_job_arg(): - with open(QUEUE_FILE, 'r') as f: - line = f.readline() + await do_the_job(job=job) + jobs.mark_job_done() def main(): print('getting event loop') loop = asyncio.get_event_loop() print('got event loop') - # loop.call_soon(test) + loop.call_soon(jobs_runner) try: os.unlink('server_sock') print('creating coro...') -- cgit v1.2.3