超时后多线程杀死线程 - python 2.7

Question

我正在运行一个异步程序，我启动的每个线程，我都想要它

有一个超时，如果它没有完成功能，它会停止并杀死自己（或者其他一些线程会杀死它）

func(my_item, num1, num2, num3, timeout):
    calc = num1+num2
    # something that takes long time(on my_item)

for item in my_list:
        if item.bool:
            new_thread = threading.Thread(target=func, (item, 1, 2, 3, item.timeout))
            new_thread.start()

现在我希望主线程继续启动新线程，但我也希望每个线程都有一个超时时间，这样线程就不会永远继续下去。

我使用的是 Windows 而不是 UNIX，所以我无法运行 SINGLRM

谢谢！

Answer 1

杀死线程是一种不好的做法，长时间运行的函数最好检查状态标志并自行退出，而不是外部因素突然杀死线程。一个简单的检查，用 time.time() 记录函数调用的开始时间，并每隔一段时间进行比较，即：

def func(x, y, timeout):
    start = time.time()
    while time.time() < (start + timeout):
        # Do stuff

或者添加一个函数可以间隔调用的方法，当超过超时时间时会引发异常，您的长时间运行的函数可以在 try/except 块中捕获以清理并退出线程：

def check_timeout(start_time, timeout):
    if time.time() > (start_time + timeout):
        raise TimeoutException

try:
    # Stuff
    check_timeout(start_time, timeout)
    # Bit more stuff
    check_timeout(start_time, timeout)
    # Bit more stuff
    check_timeout(start_time, timeout)
    # Bit more stuff
    # All done!
    return "everything is awesome"

except TimeoutException:
    # Cleanup and let thread end

我会推荐这个帖子作为一个很好的阅读：Is there any way to kill a Thread in Python?