每 x 秒调用一次函数（Python）[重复]

Question

我想每 10 秒调用一次函数（实际上是一个 Web API）。但是该函数可能需要随机 t 秒才能返回。 （假设 t 为 0.1 到 1.0 秒）

我们能想到的最简单的代码是

while True:
    func()          # take t sec
    time.sleep(10)  # sleep 10 sec

但在这种情况下，func 每 (1+t) 秒调用一次。 有更好的方法吗？

我们应该使用一些多线程或类似的东西吗？具体的代码示例将不胜感激。谢谢。

Answer 1

只要记住下一次迭代应该发生的时间，大致是这样的（不是完全工作的代码，我相信你可以从这里弄清楚）：

import time
nexttime = time.time()
while True:
    func()          # take t sec
    nexttime += 10
    sleeptime = nexttime - time.time()
    if sleeptime > 0:
        time.sleep(sleeptime)

Answer 2

试试这个：

from multiprocessing import Pool
import time

pool = Pool(processes=1)              # Start a worker processes.
while true:
    result = pool.apply_async(func, [10], callback=finish) # Evaluate "func(10)" asynchronously calling callback when finished.
    time.sleep(10)

这将恰好每 10 秒调用一次您的函数。只要您确定返回时间不会超过 10 秒，您应该可以只使用一个工作进程。来源：Asynchronous method call in Python?

Answer 3

我发现了另一种使用sched 模块的方法。

import time
import sched

def daemon(local_handler, t):
    print('time {}'.format(t))
    # call func here
    # time.sleep(2)
    local_handler.enterabs(t + 10, 1, daemon, (local_handler, t+10))

handler = sched.scheduler(time.time, time.sleep)
t = time.time()
handler.enter(0, 1, daemon, (handler, t))
handler.run()

这种方法的一个优点是我们可以精确地控制函数的时间。比如我们可以在时钟为0.31, 10.31, 20.31, 30.31, ...时调用该函数

此代码取自Python Scheduler vs loop + sleep。

Answer 4

你可以这样使用：

import time
start=time.perf_counter()
call_new_func()
while ((time.perf_counter()-start)<desired_time_wait):
    pass #busy-wait

在您的 while True 循环中。