時間のかかる処理(例えばネットワーク通信処理など)を並行実行するコードを作成しました。
これに加え、時間のかかる処理の内部で例外が発生した場合は、
未実行の処理を実行させないようにしたいのですが、どのようにすればよいでしょうか?
(並行で実行中のメソッドはそのまま実行されるのは仕方ないと考えています。)
また応用として、時間のかかる処理で10回以上例外が発生したら、以降の処理は実行しないようにしたい(キャンセルしたい)のですが、可能でしょうか。
キャンセルする条件が成り立ったら、全てのfutureオブジェクトに対し、cancelメソッドを実行すればできそうなのですが、
ループとなるためスマートでなく、他によい方法があるのではないのかと思い質問しました。
import time
from concurrent.futures import ThreadPoolExecutor
def func(value: int) -> str:
# この関数内部で例外が発生したら、他のスレッドも停止状態にしたい。
time.sleep(1)
return f'Value:[{value}]'
with ThreadPoolExecutor(max_workers=2) as executor:
future_list = executor.map(func, range(0, 10), timeout=5)
for value in future_list: # 実行結果を表示
print(value)
以下、サンプルの実行結果です。
Value:[0]
Value:[1]
Value:[2]
Value:[3]
Value:[4]
Value:[5]
Value:[6]
Value:[7]
Value:[8]
Value:[9]