Python - 長時間実行されているtaskqのスレッドを停止する

Question

私は、taskqに追加された各タスクが実行中で、何かを計算している、例えば30秒というかなり単純なプログラムを持っています。このタスクはwhileやforのループで実行されていません。

def run(self): 
    while not self.stopper.is_set(): 
     DO_MY_30_SECONDS_WORK(self) 
     self.task_done() 

ここで、私はthread.eventを持っていると仮定し、これはタスクが完了する前/後にチェックすることができます。しかし、すでに実行中のスレッドに実行を停止または終了するよう指示する方法があります。

Answer 1

DO_MY_30_SECONDS_WORK(self)がブロックしている場合は、実行中のスレッドを停止する方法はありません。間違いなくあなたはdaemonスレッドとして設定することができ、メインプログラムの実行が終了すると突然終了します。スレッドが実際にリソースを保持している場合（たとえばファイルへの書き込みなど）、一般的には終了しないと問題が発生しますスレッド。

あなたができることは、DO_MY_30_SECONDS_WORK(self)を再設計して、それをノンブロッキングにすることです。これは、作品を小さな断片に切断し、妥当な間隔で停止標識をチェックすることを意味します。あなたがそうするように言うと、自分自身を完成させます。