5

我有一个代码块，用于每 30 秒运行一段代码

def hello():
    print "hello, world"
    t = threading.Timer(30.0, hello)
    t.start()

下面是一个类的方法，我真的想每 30 秒运行一次，但我遇到了问题。

def continousUpdate(self, contractId):    
    print 'hello, world new'
    t = threading.Timer(30.0, self.continousUpdate, [self, contractId],{} )
    t.start()

当我运行它时，我收到以下错误

pydev debugger: starting
hello, world new
Exception in thread Thread-4:
Traceback (most recent call last):
  File "C:\Python27\lib\threading.py", line 552, in __bootstrap_inner
   self.run()
  File "C:\Python27\lib\threading.py", line 756, in run
   self.function(*self.args, **self.kwargs)
TypeError: continousUpdate() takes exactly 2 arguments (3 given)

我也试过

def continousUpdate(self, contractId):    
    print 'hello, world new'
    t = threading.Timer(30.0, self.continousUpdate(contractId))
    t.start()

它以某种方式表现得好像它忽略了线程，并给出了递归限制错误

4

2 回答 2

17

尝试这个：

t = threading.Timer(30.0, self.continousUpdate, [contractId],{} )

当您阅读self.continuousUpdate时，该方法已经绑定到该对象，即使您还没有调用它。你不需要self再次通过。

第二个版本“忽略线程”的原因是您在调用的参数中调用该方法Timer，因此它在 Timer 启动之前运行（并尝试再次调用自身）。这就是为什么线程函数让你分别传递函数及其参数（所以它可以在准备好时调用函数本身）。

顺便说一句，您拼写了“连续”错误。

于 2012-08-06T05:24:16.963 回答
0

只需删除self参数。这是一个完整的工作解决方案：

import threading
class DataCollect():
    def __init__(self):
        pass

    def hello(self):
        print("hello, world")
        t = threading.Timer(5.0, self.hello)
        t.start()
        
dataCollect = DataCollect() 
dataCollect.hello()
于 2020-12-24T11:00:42.247 回答