Как создать фоновый поток на вызов функции интервала в python?

Question

Я пытаюсь реализовать звонок, который работает в фоновом режиме. Как создать нанизанные на интервале вызова скажем, каждые 30 секунд, что вызывает следующую функцию:

self.mqConn.heartbeat_tick() 

Кроме того, как бы я остановить эту тему?

Большое спасибо.

Answer 1

Используйте нить, содержащей петлю

from threading import Thread 
import time 

def background_task(): 
    while not background_task.cancelled: 
     self.mqConn.heartbeat_tick() 
     time.sleep(30) 
background_task.cancelled = False 

t = Thread(target=background_task) 
t.start() 

background_task.cancelled = True 

---

В качестве альтернативы, вы можете подклассы таймера, чтобы отменить легко:

from threading import Timer 

class RepeatingTimer(Timer): 
    def run(self): 
     while not self.finished.is_set(): 
      self.function(*self.args, **self.kwargs) 
      self.finished.wait(self.interval) 


t = RepeatingTimer(30.0, self.mqConn.heartbeat_tick) 
t.start() # every 30 seconds, call heartbeat_tick 

# later 
t.cancel() # cancels execution 

Answer 2

Один из способов сделать это было бы использовать рамки circuits приложения вроде этого:

from circuits import Component, Event, Timer 


class App(Component): 

    def init(self, mqConn): 
     self.mqConn = mqConn 
     Timer(30, Event.create("heartbeat"), persist=True).register(self) 

    def heartbeat(self): 
     self.mqConn.heartbeat_tick() 


App().run() 

Примечание: Я автор схем :)

Это лишь основная идея и структура - вам нужно будет адаптировать это в соответствии с вашими точными требованиями и требованиями!

Answer 3

Или вы могли бы использовать класс Timer в модуле потоковой :

from threading import Timer 

def hello(): 
    print "hello, world" 

t = Timer(30.0, hello) 
t.start() # after 30 seconds, "hello, world" will be printed 
t.cancel() # cancels execution, this only works before the 30 seconds is elapsed 

Это не будет запускаться каждые x секунд, а скорее задерживает поток для выполнения за x секунд. Но вы все равно можете поместить это в цикл и использовать t.is_alive(), чтобы увидеть его статус.

Answer 4

Быстрый ответ на вопрос Eric: вы не можете подкласса Timer, так как на самом деле это оболочка световой функции вокруг истинного класса: _Timer. Если вы это сделаете, вы получите сообщение об ошибке, которое появится в this post.

Использование _Timer вместо фиксирует это:

from threading import _Timer 

class RepeatingTimer(_Timer): 
    def run(self): 
     while not self.finished.is_set(): 
      self.function(*self.args, **self.kwargs) 
      self.finished.wait(self.interval) 


t = RepeatingTimer(30.0, self.mqConn.heartbeat_tick) 
t.start() # every 30 seconds, call heartbeat_tick 

# later 
t.cancel() # cancels execution