Python uyurken bir iş parçacığı sonlandır

Question

Aşağıdaki kodu bu link numaralı telefondan ilk yanıttan değiştirdim.

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() 

Ben bu sınıfın bir örneğini oluşturmak ve süreci deamon olarak ayarlayın sonra bunu daha sonra _target() işlevi tamamlamak ve için iplik uyurken başka, daha sonraki bir zamanda sonlandırmak beklemek istiyorum sonlandırabilir. İkinci durumu durma yöntemini arayarak halledebilirim. Ancak, _awake olay nesnesi False olarak ayarlandığında onu sonlandırma hakkında hiçbir fikrim yok. Birisi lütfen yardım edebilir mi?

Answer 1

Kişisel bilgileriniz açıkça sleep olmalıdır. Başka bir evre için durmasını istemek için bekleyebilir.

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() 

Bu amaçla, size hiç awake olayı gerekmez. (Başka bir iş parçacığının "durumunu" kontrol etmek istiyorsa yine de buna ihtiyacınız olabilir. Bunun sizin için bir gereksinim olup olmadığını bilmiyorum).

awake olmadan, kod olacaktır:

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()