Pythonについて。
只今、『入門 Python3』を読みながら、
JupyterLabを使ってPythonを学んでいます。
OSはwindows10です。
『11.1.2 プロセス』より。
以下のコードは、皿洗いプロセスと乾燥プロセスで仕事を分担し、JoinableQueue
を使って、その間で通信をしながらタスクを処理するというプログラムです。
1つの皿洗いプロセスと複数の乾燥担当プロセスがあり、間にdish_queue
があります。
本に書かれてある通りに書いてもエラーが発生して実行できないため、
if __name__ == '__main__' :
の行を追加しています。
import multiprocessing as mp
# 皿洗い担当の定義をする。
def washer(dishes, output) :
for dish in dishes :
print('Washing', dish, 'dish')
output.put(dish)
# 皿の乾燥担当の定義をする。
def dryer(input) :
while True :
dish = input.get()
print('Drying', dish, 'dish')
input.task_done()
# mp.JoinableQueueオブジェクトを定義し、乾燥担当をデーモンプロセスにして待機させておく。
dish_queue = mp.JoinableQueue()
if __name__ == '__main__' :
dryer_process = mp.Process(target = dryer, args = (dish_queue,))
dryer_process.daemon = True
dryer_process.start()
# 皿のリストを定義し、皿洗い担当を実行する。
# 最終行で、mp.JoinableQueueオブジェクトのjoin()メソッドを使い、洗った皿(タスクキュー)を皿洗い担当から乾燥担当に渡す。
dishes = ['salad', 'bread', 'entree', 'dessert']
washer(dishes, dish_queue)
dish_queue.join()
これを実行すると、本来はこのようになります。
Washing salad dish
Washing bread dish
Washing entree dish
Washing dessert dish
Drying salad dish
Drying bread dish
Drying entree dish
Drying dessert dish
しかし、実際には、
Washing salad dish
Washing bread dish
Washing entree dish
Washing dessert dish
Washing salad dish
Washing bread dish
Washing entree dish
Washing dessert dish
と表示されました。
なんということでしょうか、皿を二度も洗っています。
ここで質問です。
1.このコードは、どうすれば想定通りの結果になりますか?
2.この一連の流れは、同期的と言えますか?それとも非同期的でしょうか?
尚、言葉や言葉の使い方が正確ではないことがあります。
本文中、気になることがございましたら、何なりとご指摘くださいませ。
それは、自身の成長のために必要なことだと思っております。