【Python】Queueを使って複数スレッドをうまく活用する方法 | Udemyのセールを活用してほしかったあのスキルを手に入れよう！【非公式】

Python学習【365日チャレンジ！】214日目のマスターU（@Udemy11）です。

住んでいるところは結構田舎なのですが、先日なにやらヘリコプターのような音がするので、外をみてみると、なんとびっくり、ドローンで田んぼの消毒をしていました。

稲から1mくらい上空をきれいにまっすぐ飛んでいくので、思わず見入ってしまったのですが、ほんとこんな田舎までテクノロジーが浸透しているのかと感心してしまいました。

3Dマップでプログラミングして飛ばしているのかと思ったのですが、よくよく見ると遠くの方でリモコンを操作している人がいたので、自動化できているわけではなさそうでした。

それにしてもテクノロジーの発展はすごい勢いで進んでるようですね。

それでは、今日もPython学習をはじめましょう。

昨日の復習

昨日は、queueの応用的な使い方ついて学習しました。

時間のかかる処理をjoinを使って待機してtask.doneで終了を確認してスレッドを終了するというやり方をしました。

デバッグを使うと、処理があっち行ったりこっち行ったりするのがわかるので、トライアンドエラーで試してみることが大切でした。

Udemyのセールを活用してほしかったあのスキルを手に入れよう！【非公式】

2020.09.11

【Python】Queueのもう少し高度な使い方

https://udemyfun.com/python-how-to-use-queue

Python学習【365日チャレンジ！】213日目のマスターU（@Udemy11）です。この間、かなり近くでトンビをみました。最初はカラスかなと思っていたのですが、近づいてみるとくちばしがかっこよく曲がったトンビだったので、写真を撮ったのですが、近づきすぎたみたいですぐに飛んでいってしまいました。10匹くらいいて、近づくと飛んでいくんですが、羽を広げるとかなり大きいのでびっくりしました。「トンビが鷹を生む」なんて言葉がありますが、個人的にはどっちがどっちやら見分けがつかないので、トンビと鷹でそんな差があるのかな？な...

今日は、さらに突っ込んだキュー（queue）のより実践的な使い方を学習します。

3つのスレッドで処理する

時間のかかる処理を3つのスレッドで並列処理をするコードを考えてみましょう

import logging
import queue
import threading

logging.basicConfig(level=logging.DEBUG, format='%(threadName)s: %(message)s')

def thread1(queue):
    logging.debug('start1')
    while True:
        item = queue.get()
        if item is None:
            break
        logging.debug(item)
        queue.task_done()

    logging.debug('very long work')
    logging.debug('end1')

if __name__ == '__main__':
    queue = queue.Queue()
    for i in range(100000):
        queue.put(i)
    ts = []
    for _ in range(3):
        t = threading.Thread(target=thread1, args=(queue, ))
        t.start()
        ts.append(t)
    queue.join()
    logging.debug('tasks are finished')
    for _ in range(len(ts)):
        queue.put(None)

    [t.join() for i in ts]

20行目までは昨日と同じコードです。

21行目で、なんとびっくり10万回queueに値を代入するforループにして、23行目でthreadを入れる空のリストtsを定義しています。

24行目から27行目で、関数thread1を並列処理で実行する3つのthreadを作成して、先程作ったリストtsに追加します。

28行目のjoinでqueueが終了するのを待って、30行目、31行目でtsに入っているスレッドの数だけqueueにNoneを代入しています。

これでthread1のitemにNoneが3回代入されてwhileループがbreakして、3つのスレッドが終了します。

33行目はリスト内包表記ですが、覚えていますか？