1

我试图每秒运行一个特定的函数“foo”。我必须这样做几分钟（比如5）。

函数 foo() 向服务器发出 100 个 HTTP 请求（其中包含一个 JSON 对象）并打印 JSON 响应。

简而言之，我必须在 5 分钟内每秒发出 100 个 HTTP 请求。

我刚刚开始学习python，因此没有广泛的知识。这是我尝试过的：

import threading
noOfSecondsPassed = 0
def foo():
   global noOfSecondsPassed
   # piece of code which makes 100 HTTP requests (I use while loop)
   noOfSecondsPassed += 1

while True:
   if noOfSecondsPassed < (300)  # 5 minutes
       t = threading.Timer(1.0, foo)
       t.start()

由于多线程，函数 foo 没有被调用 300 次，但远不止于此。我也尝试过设置锁：

def foo():
  l = threading.Lock()
  l.acquire()
  global noOfSecondsPassed
  # piece of code which makes 100 HTTP requests (I use while loop)
  noOfSecondsPassed += 1
  l.release()

其余代码与前面的代码片段相同。但这也行不通。

我该怎么做呢？

编辑：不同的方法

我已经尝试过这种对我有用的方法：

def foo():
    noOfSecondsPassed = 0
    while noOfSecondsPassed < 300:
       #Code to make 100 HTTP requests
       noOfSecondsPassed +=1
       time.sleep(1.0)
foo()

这样做有什么坏处吗？

4

1 回答 1

1

我会使用另一种我认为更容易的方法。

创建 300 个计时器线程，每个线程在前一个之后运行 1 秒。主循环几乎在瞬间执行，因此错误率非常低。这是一个示例演示：

import datetime
import thread
import threading

def foo():
     print datetime.datetime.now()
     print threading.active_count()

for x in range(0,300): 
     t = threading.Timer(x + 1, foo)
     t.start()

此代码输出应如下所示：

2012-10-01 13:21:07.328029
301
2012-10-01 13:21:08.328281
300
2012-10-01 13:21:09.328449
299
2012-10-01 13:21:10.328615
298
2012-10-01 13:21:11.328768
297
2012-10-01 13:21:12.329006
296
2012-10-01 13:21:13.329289
295
2012-10-01 13:21:14.329369
294
2012-10-01 13:21:15.329580
293
2012-10-01 13:21:16.329793
292
2012-10-01 13:21:17.329958
291
2012-10-01 13:21:18.330138
290
2012-10-01 13:21:19.330300                                                                                                                                                                                                                         
289                         
...

如您所见，每个线程在前一个线程之后大约 1 秒启动，并且您正在启动 300 个线程。

于 2012-10-01T12:15:36.387 回答