2

我有一些定期运行的代码，并且不时地（比如每月一次）程序似乎挂在某个地方，我不确定在哪里。

我想我会实施[结果不完全是]检查程序运行了多长时间的“快速修复”。我决定使用多线程来调用该函数，然后在它运行时检查时间。

例如：

import datetime
import threading

def myfunc():
  #Code goes here

t=threading.Thread(target=myfunc)
t.start()
d1=datetime.datetime.utcnow()
while threading.active_count()>1:
  if (datetime.datetime.utcnow()-d1).total_seconds()>60:
    print 'Exiting!'
    raise SystemExit(0)

但是，这不会关闭另一个线程 (myfunc)。

杀死另一个线程的最佳方法是什么？

4

2 回答 2

3

文档可能对此更清楚。提升SystemExit告诉解释器退出，但“正常”退出处理仍然完成。正常退出处理的一部分是.join()-ing 所有活动的非守护线程。但是你的流氓线程永远不会结束，所以退出处理永远等待加入它。

正如@roippi 所说，你可以做到

t.daemon = True

在开始之前。正常退出处理不等待守护线程。当主进程退出时，您的操作系统应该杀死它们。

另一种选择：

import os
os._exit(13)  # whatever exit code you want goes there

这会“立即”停止解释器，并跳过所有正常的退出处理。

选择你的毒药;-)

于 2013-09-23T03:59:05.833 回答
1

没有办法杀死线程。你必须从目标内部杀死目标。最好的方法是使用钩子和队列。它是这样的。

import Threading
from Queue import Queue

# add a kill_hook arg to your function, kill_hook
# is a queue used to pass messages to the main thread
def myfunc(*args, **kwargs, kill_hook=None):
  #Code goes here
  # put this somewhere which is periodically checked.
  # an ideal place to check the hook is when logging
  try:
    if q.get_nowait():  # or use q.get(True, 5) to wait a longer
      print 'Exiting!'
      raise SystemExit(0)
    except Queue.empty:
      pass

q = Queue()  # the queue used to pass the kill call
t=threading.Thread(target=myfunc, args = q)
t.start()
d1=datetime.datetime.utcnow()
while threading.active_count()>1:        
  if (datetime.datetime.utcnow()-d1).total_seconds()>60:
  # if your kill criteria are met, put something in the queue
    q.put(1)

我最初在网上的某个地方找到了这个答案，可能是这个。希望这可以帮助！

另一种解决方案是使用单独的 Python 实例，并使用psutils监视另一个 Python 线程，从系统级别将其杀死。

哇，我也喜欢守护进程和隐形 os._exit 解决方案！

于 2013-09-23T03:56:02.340 回答