Python，threading.timer 对象不会运行函数定时器？

Question

我正在尝试延迟发送电子邮件，因为发送电子邮件的条件可能会开启很长一段时间，我不想收到无限量的电子邮件警报...

为此，我正在尝试使用 threading.timer 来延迟它，并且每 15 分钟才发送一次电子邮件...我尝试了 .timer 对象上的 900 秒长延迟并且它有效(使用时间脚本)。 ..但是当我运行它发送电子邮件时，它首先发送电子邮件，然后进入计时器而不运行脚本的其他部分......电子邮件功能工作得很好......运行 python 2.6.6

#!/usr/bin/env python

import time
import smtplib #for sending emails when warning
import threading

if True: #the possibility exists that the conditional is met several times thus sending lots of emails
    t = threading.Timer(300,send_email('Tank temperature Overheat',tank_temp))
    t.start() # after 300 seconds, the email will be sent but the script will keep running
print "rest of the script keeps running"
print "keeps running the scrpit and after 300s the email is sent"

关于为什么它不起作用或其他解决方法的任何想法？

玩完之后...它会休眠但会发送所有电子邮件...不是每 X 时间设置的电子邮件...即

n=300

start = time.time()

while (time.time() - start < n):

    led_temp = 56

        if led_temp > 55:
        t = threading.Timer(100, lambda: send_email('Lights temperature Overheat',led_temp))
        t.start()

我不是每 100 秒收到一封电子邮件，而是在 300 秒后收到 36 封电子邮件.. ??知道为什么吗？ (从下面的评论重新格式化)

阅读关于线程的答案后，我明白了这个问题......我仍然知道 python 并且从未使用过用户线程所以我猜这是我在创建无限量线程时收到的 36 封电子邮件的根本原因......我通过使用标志修复了它，并测试了这样的代码:

def raise_flag():
    global start
    interval = 300
    if start > interval:
        start = 0
        flag = True
        print "Flag True, sending email"
        return flag
    else:
        flag = False
        start = start + 1
        print "Flag OFF", start
        time.sleep(1)
        return flag

led_temp = 27
while led_temp > 26:
    flag = raise_flag()
    if flag:
        send_email('Tank temperature Overheat',led_temp)
        flag = False
        print "Sent email"

Answer 1

作为 timer 的第二个参数，您应该传递一个可调用对象，但在您的情况下，您正在调用该函数并将结果传递给 threading.Timer。您应该改用 lambda 表达式:

#!/usr/bin/env python

import time
import smtplib
import threading

if True:
    t = threading.Timer(300, lambda: send_email('Tank temperature Overheat',tank_temp))
    t.start() 
print "rest of the script keeps running"
print "keeps running the scrpit and after 300s the email is sent"

表达式:

lambda: send_email('Tank temperature Overheat',tank_temp)

评估一个没有参数的函数，当调用时使用该参数执行 send_email，而在您的代码中您有:

t = threading.Timer(300,send_email('Tank temperature Overheat',tank_temp))

这将首先评估所有参数，然后调用 send_email，然后创建 Timer 对象。

---

关于 300 秒内 36 封电子邮件的问题，在您的代码中:

n=300

start = time.time()

while (time.time() - start < n):

    led_temp = 56

        if led_temp > 55:
        t = threading.Timer(100, lambda: send_email('Lights temperature Overheat',led_temp))
        t.start()

while 将在 300 秒的迭代期间创建大量线程。我不知道为什么你认为这个循环应该每 100 秒给你发一封电子邮件。每个线程都会在 100 秒后向您发送一封电子邮件，但是线程很多。

如果您只想发送 3 封电子邮件，那么您应该在三次迭代后break 退出循环。此外，迭代可能太快了，因此所有计时器将几乎同时发送所有电子邮件，因为它们的超时时间几乎相等。

你可以通过下面的代码看到这个问题:

>>> import threading
>>> import threading
>>> def send_email(): print("email sent!")
... 
>>> for _ in range(5):
...     t = threading.Timer(7, send_email)
...     t.start()
... 
>>> email sent!
email sent!
email sent!
email sent!
email sent!

即使创建了 5 个不同的 Timer，它们几乎同时超时，所以您会看到所有 email sent! 同时出现。您可以修改超时以考虑到这一点:

>>> for i in range(5):
...     t = threading.Timer(7 + i, send_email)
...     t.start()
... 
>>> email sent!
email sent!
email sent!
email sent!
email sent!

在上面的代码中，您将看到 email sent! 一次出现一个，间隔大约为 1 秒。

最后我要补充一点，您无法控制何时收到电子邮件。这由不同的服务以不同的方式处理，因此无法保证在运行您的代码时收件人每 100 秒会收到一封电子邮件。