Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #!/usr/bin/env python3
- # -*- coding: utf-8 -*-
- import asyncio
- loop = asyncio.get_event_loop()
- class Result:
- def __init__(self):
- self.result = None
- self.event = asyncio.Event()
- self.is_stopped = False
- async def createGenerator(res):
- mylist = range(3)
- for i in mylist:
- await asyncio.sleep(1)
- res.result = i*i
- res.event.set()
- res.is_stopped = True
- res.event.set()
- async def start():
- res = Result()
- loop.create_task(createGenerator(res))
- while True:
- await res.event.wait()
- print (res.result)
- if res.is_stopped:
- break
- res.event.clear()
- try:
- loop.run_until_complete(start())
- except KeyboardInterrupt:
- loop.stop()
- pass
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement