・0 pv・3 min read
Pythonの並行処理を一番わかりやすく(サンプルコードあり)
こちらの記事（Pythonの並行処理を理解したい [マルチスレッド編]）を参考にさせていただきました
一つの関数に引数があるときにうまくいかなかったのでそのメモとして書きます。
★★★この記事は簡単に使い方をまとめたものです。メリットだけではないので上の記事など読むことをおすすめします。★★★
並行して実行したい関数に引数がないとき
from concurrent.futures.thread import ThreadPoolExecutor
import time
# 待つ関数を３つ用意する。
def wait_one_second():
time.sleep(1)
print("1秒間待つ処理が終了しました。")
def wait_five_seconds():
time.sleep(5)
print("5秒間待つ処理が終了しました。")
def wait_ten_seconds():
time.sleep(10)
print("10秒間待つ処理が終了しました。")
# それらを束ねる関数を、普通に処理する場合と、並行処理する場合、それぞれ作る。
def run_normally_without_arg():
""" 普通に処理する場合 """
wait_ten_seconds()
wait_five_seconds()
wait_one_second()
def run_concurrent_without_arg():
""" 並行処理する場合 """
with ThreadPoolExecutor() as executor:
executor.submit(wait_ten_seconds)
executor.submit(wait_five_seconds)
executor.submit(wait_one_second)run_normally_without_arg()10秒間待つ処理が終了しました。
5秒間待つ処理が終了しました。
1秒間待つ処理が終了しました。
run_concurrent_without_arg()1秒間待つ処理が終了しました。
5秒間待つ処理が終了しました。
10秒間待つ処理が終了しました。
並行して実行したい関数に引数があるとき
例えば
executor.submit(wait_some_seconds, 10, "おけ")のようにexecutor.submit(実行したい関数, 第一引数, 第二引数,・・・)とするPythonのドキュメントがこちら
from concurrent.futures.thread import ThreadPoolExecutor
import time
def wait_some_seconds(length_in_second,word):
time.sleep(length_in_second)
print(f'{length_in_second}秒間待つ処理が終了しました。 第二引数→{word}')
def run_normally_with_arg():
""" 普通に処理する場合 """
wait_some_seconds(10, "あ")
wait_some_seconds(5, "い")
wait_some_seconds(1, "う")
def run_concurrent_with_arg():
""" 並行処理を行う関数 """
with ThreadPoolExecutor() as executor:
executor.submit(wait_some_seconds,10,"あ")
executor.submit(wait_some_seconds,5,"い")
executor.submit(wait_some_seconds,1,"う")run_normally_with_arg()10秒間待つ処理が終了しました。 第二引数→あ
5秒間待つ処理が終了しました。 第二引数→い
1秒間待つ処理が終了しました。 第二引数→う
10秒間待つ処理が終了しました。 第2引数→あ
5秒間待つ処理が終了しました。 第2引数→い
1秒間待つ処理が終了しました。 第2引数→う
run_concurrent_with_arg()