线程计时器问题python



我正在尝试使用线程。定时器类,但总是死机。我的想法是这样的:我有一段代码,可以在一个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);

相关内容

  • 没有找到相关文章

最新更新