Q&A作成したthreadsで queueを使った処理を始めて、処理が終わる前に、新たなthreadsを追加して、queueにアクセスしたいです。
queue.join()によって、全てのqueueが取り出されるまで処理がブロックされているのですが、queue.join()をつかわないと、そもそもqueueへのアクセスが開始できません。
queueのアクセスを開始できて、その後も終了前にqueueにアクセスするにはどうすればいいのでしょうか？
python
1import queue 2import threading 3import time 4 5def login(queue, driver_num): 6 while True: 7 task = queue.get() 8 time.sleep(2) 9 queue.task_done() 10 print(f'driver{driver_num} : task{task}') 11 12queue = queue.Queue() 13 14def create_thread(driver_num): 15 thread = threading.Thread(target=login, args=(queue, driver_num,), daemon=True) 16 thread.start() 17 18create_thread(1) 19create_thread(2) 20 21f=open('data.txt') 22data_list=f.read() 23for data in data_list.split('\n'): 24 if data!='': 25 queue.put(data) 26queue.join() 27 28create_thread(3) 29 30f=open('data.txt') 31data_list=f.read() 32for data in data_list.split('\n'): 33 if data!='': 34 queue.put(data) 35queue.join() 36
result
1driver1 : taskA 2driver2 : taskB 3driver1 : taskC 4driver2 : taskD 5driver1 : taskE 6driver2 : taskF 7driver1 : taskG 8driver2 : taskH 9driver1 : taskI 10driver2 : taskJ 11driver2 : taskL 12driver1 : taskK 13driver2 : taskM 14driver1 : taskN 15driver2 : taskA 16driver3 : taskB 17driver1 : taskC 18driver2 : taskD 19driver3 : taskE 20driver1 : taskF 21driver2 : taskG 22driver3 : taskH 23driver1 : taskI 24driver2 : taskJ 25driver3 : taskK 26driver1 : taskL 27driver2 : taskM 28driver3 : taskN
回答1件
0
自己解決
daemon=True
を削除したところ、queue.join()と、queue.task_done()を使わなくても実行できました。
投稿2022/07/31 09:43
総合スコア126
あなたの回答
tips
プレビュー
バッドをするには、ログインかつ
こちらの条件を満たす必要があります。