Pythonはスリープ中にスレッドを終了します

Question

次のコードをこのlinkの最初の答えから変更しました。

class StoppableThread(threading.Thread): 
    """Thread class with a stop() method. The thread itself has to check 
    regularly for the stopped() condition.""" 

    def __init__(self, target, timeout): 
     super(StoppableThread, self).__init__() 
     self._target = target 
     self._timeout = timeout 
     self._stop = threading.Event() 
     self.awake = threading.Event() 

    def run(self): 
     while(not self._stop.isSet()): 
      self.awake.clear() 
      time.sleep(self._timeout) 
      self.awake.set() 
      self._target() 

    def stop(self): 
     self._stop.set() 

    def stopped(self): 
     return self._stop.isSet() 

私は、このクラスのインスタンスを作成し、デーモンプロセスにそれを設定したら、私はスレッドが眠っているとき、後でそれを終了したいと思い、そうでなければ_target()機能を完了するのを待ってから、終了する。 stopメソッドを呼び出すことで後者のケースを処理できます。しかし、_awakeイベントオブジェクトがFalseに設定されているときに終了することはできません。誰かが助けてくれますか？

Answer 1

あなたのスレッドは明示的にsleepを必要としません。別のスレッドが停止を要求するのを待つだけです。

def run(self): 
    while(not self._stop.isSet()): 
     self.awake.clear() 
     self._stop.wait(self._timeout) # instead of sleeping 
     if self._stop.isSet(): 
      continue 
     self.awake.set() 
     self._target() 

この目的のために、あなたはまったくawakeイベントを必要としません。 （別のスレッドが "ステータス"を確認したい場合には、まだそれが必要かもしれませんが、あなたが持っている必要があるかどうかわかりません）。

awakeがなければ、あなたのコードは次のようになります。

class StoppableThread(threading.Thread): 

    def __init__(self, target, timeout): 
     super(StoppableThread, self).__init__() 
     self._target = target 
     self._timeout = timeout 
     self._stop = threading.Event() 

    def run(self): 
     while not self.stopped(): 
      self._stop.wait(self._timeout) # instead of sleeping 
      if self.stopped(): 
       continue 
      self._target() 

    def stop(self): 
     self._stop.set() 

    def stopped(self): 
     return self._stop.isSet()