pythonでエラーが起きたときに中断する方法について

Question

mainで受け取ったItems(人の名前のリスト)を
マルチスレッドで並列化しその人の詳細情報を取得するプログラムを作っています。

10人リストを渡した時に詳細情報が存在しない場合に
処理を中断することを考えているのですがsubmain()にbreakを置いたことで
以下のプログラムではエラーが発生します。
'break' outside loop

breakはループの中(for)でおくべきものなので当然ですが。。
どのように対処すればよいでしょうか？

def main(Items):
    mult = ThreadPoolExecutor(max_workers=10, thread_name_prefix="thread")
    for Item in Items:
        mult .submit(submain,Item)
    mult.shutdown()

def submain(Item):
    try:
        result = get_attr(Item)
    except KeyError as ex:
　　　　 SetErrorMassage('Error001')
        break
    dict = {'name':result['name']}

dictRes = dict()
if dict is not None:
　 return dict 
else
   dictRes = GetErrorMassage()
   return dictRes 

Answer 1

非同期処理なのですね。
for文の実行中にエラーが起きるかもしれないし、mult.shutdown()で全ての終了を待っている間にエラーが起きるかもしれないので、全てをtry節に入れましょう。

ただ、resultを使っていないので、これをどうにかしないと役に立たないと思います。外部変数の配列に入れるとかしないと結果を使えないからです。

def main(Items):
    mult = ThreadPoolExecutor(max_workers=10, thread_name_prefix="thread")
    try:
　　　　for Item in Items:
       　　 mult .submit(submain,Item)
        mult.shutdown(wait=True)
    except KeyError as ex:
        print(ex)
        exit(-1)

def submain(Item):
    result = get_attr(Item)

これでエラーを拾っても、残っているスレッドで別のエラーが起きると、try節の外でエラーを受け取って落ちるので、exitさせています。
これがいやなら、全てのスレッドを別の方法で殺す必要があります。

Comments

[pokemonta]

exit(-1)しかdefを抜ける（中断する）方法ありませんか？

[ppaul]

抜けたいだけならreturnしてもいいのですが、そのあとでも子スレッドが異常を起こして、tryでは拾えないためにトレースを出して止まるということです。
回答に書きましたように、そのあとも処理を続けたいなら、workerのスレッドを全部止めないといけないということです。

Answer 2

処理を中断ということは、エラーで停止させてはいかがですか？
要するに、try&except文を消すまたは、except文の中にraise文を入れて、エラーを起こすでどうでしょう。
すると、mult.submit(省略)の返り値done?をみれば、まあダイジョブではないでしょうか。
それか、returnでエラー値を返しておくのもいいかもしれません。
returnのあとは、すべて無視されます。(関数内で)

Answer 3

submain関数で、情報が存在してるときはtrue、存在しない場合（エラーが出る場合）はfalseを返しておくようにしておいて、
呼び出し側で、その関数からfalseが帰ってきたときにbreakを実行するようにしておけばいいです