我正在尝试使用线程。定时器类,但总是死机。我的想法是这样的:我有一段代码,可以在一个web应用程序上启动一个优化。当优化启动时,我想定期向web应用服务器发送请求,以了解优化是否完成,或仍在执行。
def checkPeriodically(self):
print "Sending a request"
finished = self.checkOptim()
if finished :
return
t = threading.Timer(60,self.checkPeriodically)
t.start()
我的checkOptim函数使用mechanize连接到应用程序并读取结果页;然后使用HTMLParser检查优化是否完成。
def checkOptim(self):
browser = mechanize.Browser()
browser.set_handle_refresh(True, honor_time=True, max_time=10)
browser.open('resultPageURL')
response = browser.response().read()
parser = MyHTMLParser(self.optimName)
parser.feed(response)
return parser.optimFinished
所有这些都是我为QGIS(一个GIS)编写的插件的一部分,但我不认为这个问题与软件有关,这可能是由于我没有正确使用线程类。
我不知道你得到的错误消息是什么,但它可能是函数checkperiodic是它的一部分的对象不再存在了。
下面是工作代码的示例:(我一直保持对对象的引用,直到所有作业完成)
import threading
import time
class cls:
def __init__(self):
pass
self.stop_if_zero = -10
def checkPeriodically(self):
print "Sending a request %s" % self.stop_if_zero
self.stop_if_zero +=1;
if 0 == self.stop_if_zero :
return
t = threading.Timer(2,self.checkPeriodically)
t.start()
#create instance of the class
st = cls()
#start the thread with timer
st.checkPeriodically();
while (0 > st.stop_if_zero ):
# keep referance to ST untill it ends or else it might crashed.
time.sleep (0.1);