Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import queue
- def task(name,queue):
- while not queue.empty():
- count = queue.get()
- print("Очередь",count)
- total = 0
- print("Name",name,'running')
- for x in range(count):
- total+=1
- yield
- print("Name",name,'total',total)
- def main():
- work_queue = queue.Queue()
- for work in [15,10,5,2]:
- work_queue.put(work)
- tasks = [task('One',work_queue),task('Two',work_queue)]
- done = False
- count = 0
- while not done:
- for t in tasks:
- try:
- print('count',count)
- count = count + 1
- next(t)
- except StopIteration:
- print("Stop")
- tasks.remove(t)
- if len(tasks) == 0:
- done = True
- main()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement