並列処理を含むプログラムを強制終了させたい

concurrent.futuresで並列処理を行っています。
メインの文である条件を満たしたら並列処理を含むプログラムを全て強制終了させたいのですが、どうすれば良いでしょうか？
以下のプログラムではsys.exit後も並列処理funcの動作が続いてしまいます。

python
1import concurrent.futures, datetime, sys, time
2
3def func():
4  while True:
5    print("ok")
6    time.sleep(1)
7
8executor = concurrent.futures.ThreadPoolExecutor(max_workers=2)
9executor.submit(func)
10
11count = 0
12while True:
13  count = count + 1
14  time.sleep(1)
15  if count > 5:
16    sys.exit()   # funcは終了しない

行動規範の内容に同意します

回答3件

ThreadPoolExecutorを使わないでthreadingで書けば、daemonに指定することで一緒に死んでくれます。処理の複雑性にもよりますが、質問文程度であればこちらでもいいと思います。

python
1import sys
2import time
3import threading
4
5def func():
6    while True:
7        print("ok")
8        time.sleep(1)
9
10th = threading.Thread(target=func, daemon=True)
11th.start()
12
13count = 0
14while True:
15    count = count + 1
16    time.sleep(1)
17    if count > 5:
18        sys.exit()
19

投稿2019/08/24 04:35

hayataka2049

総合スコア30933

ramin

2019/08/26 15:31

ありがとうございました。

行動規範の内容に同意します

ベストアンサー

以下のようにquitフラグを利用して制御するのがお行儀がよいかと思います。
参考：How do you kill Futures once they have started?

Python
1import concurrent.futures, datetime, sys, time
2
3def func():
4  print('func start')
5  while not quit: # 終了指示されるまで
6    print('func loop')
7    time.sleep(1)
8  print('func end')
9
10print('main start')
11quit = False
12executor = concurrent.futures.ThreadPoolExecutor(max_workers=2)
13f = executor.submit(func)
14
15for _ in range(5):
16  print('main loop')
17  time.sleep(1)
18
19quit = True# 終了指示
20
21# 終了待ち
22while not f.done():
23    time.sleep(1)
24print('main end')