Как выполнять функцию асинхронно каждые 60 секунд в Python?

Question

Я хочу выполнять функцию каждые 60 секунд на Python, но я не хочу, чтобы меня блокировали между тем.

Как я могу сделать это асинхронно?

import threading 
import time 

def f(): 
    print("hello world") 
    threading.Timer(3, f).start() 

if __name__ == '__main__': 
    f()  
    time.sleep(20) 

С помощью этого кода функция f выполняется каждые 3 секунды в течение 20 секунд времени. В конце он дает ошибку, и я думаю, что это потому, что threading.timer не был отменен.

Как я могу отменить его?

Заранее благодарен!

Answer 1

Вы могли бы попробовать класс threading.Timer: http://docs.python.org/library/threading.html#timer-objects.

import threading 

def f(f_stop): 
    # do something here ... 
    if not f_stop.is_set(): 
     # call f() again in 60 seconds 
     threading.Timer(60, f, [f_stop]).start() 

f_stop = threading.Event() 
# start calling f now and every 60 sec thereafter 
f(f_stop) 

# stop the thread when needed 
#f_stop.set() 

Answer 2

Почему бы вам не создать отдельную нить, в которой вы положили простой спальный цикл:

#!/usr/bin/env python 
import time 
while True: 
    # Your code here 
    time.sleep(60) 

Answer 3

Самый простой способ - создать фоновый поток, который запускает что-то каждые 60 секунд. Простейшая реализация:

class BackgroundTimer(Thread): 
    def run(self): 
     while 1: 
     Time.sleep(60) 
     # do something 


# ... SNIP ... 
# Inside your main thread 
# ... SNIP ... 

timer = BackgroundTimer() 
timer.start() 

Очевидно, что если «делать что-то» занимает много времени, вам необходимо разместить его в вашем заявлении сна. Но это служит хорошим приближением.

Answer 4

Это зависит от того, что вы на самом деле хотите сделать в среднее время. Темы являются наиболее общим и наименее предпочтительным способом его выполнения; вы должны знать о проблемах с потоками при его использовании: не все (не-Python) коды допускают доступ из нескольких потоков одновременно, связь между потоками должна выполняться с использованием потокобезопасных структур данных, таких как Queue.Queue, вы не сможете прервать поток извне, а завершение программы, пока поток все еще работает, может привести к зависанию интерпретатора или ложных трассировок.

Часто есть более простой способ. Если вы делаете это в программе GUI, используйте таймер или функциональность библиотеки графической библиотеки. У всех GUI есть это. Аналогично, если вы используете другую систему событий, такую ​​как Twisted или другая модель процесса сервера, вы должны иметь возможность подключаться к циклу основного события, чтобы заставить его регулярно вызывать вашу функцию. Подходы, не поддерживающие потоки, заставляют вашу программу блокироваться во время ожидания функции, но не между функциональными клавишами.

Answer 5

Я googled вокруг и нашел Python circuits Framework, что позволяет подождать
для конкретного события.

.callEvent(self, event, *channels) метод цепей содержит огонь и приостановить, пока-ответ функциональность, документация говорит:

Огонь данное событие в указанных каналах и приостановить выполнение , пока он не был отправлен. Этот метод может быть вызван только как аргумент для yield на верхнем уровне выполнения обработчика (например, «yield self.callEvent(event)»). Он эффективно создает и возвращает генератор, который будет вызываться основным контуром, пока не будет отправлено событие (см. Func: circuits.core.handlers.handler).

Я надеюсь, что вы нашли это так полезно, как я :)
./regards

Answer 6

Если вы хотите, чтобы вызвать метод «на часах» (например, каждый час на час), вы можете интегрировать следующую идею с какой потоковой механизм вы выбираете:

import time 

def wait(n): 
    '''Wait until the next increment of n seconds''' 
    x = time.time() 
    time.sleep(n-(x%n)) 
    print time.asctime() 

Answer 7

Я думаю, что правильный путь, чтобы запустить поток несколько раз является следующим:

import threading 
import time 

def f(): 
    print("hello world") # your code here 
    myThread.run() 

if __name__ == '__main__': 
    myThread = threading.Timer(3, f) # timer is set to 3 seconds 
    myThread.start() 
    time.sleep(10) # it can be loop or other time consuming code here 
    if myThread.is_alive(): 
     myThread.cancel() 

С помощью этого кода функция f выполняется каждые 3 секунды в течение 10 секунд time.sleep (10). В конце бежит поток отменяется.