python - 如何使用线程池做死循环功能？

Question

我想做一个无限循环的函数。

这是我的代码

def do_request():
    # my code here
    print(result)

while True:
    do_request()

用while True做这个的时候有点慢，所以想用线程池来并发执行函数do_request()。如何做到这一点？

就像使用 ab (Apache Bench) 来测试 HTTP 服务器一样。

Answer 1

终于，我解决了这个问题。我使用一个变量来限制线程数。

这是我的最终代码，解决了我的问题。

import threading
import time

thread_num = 0
lock = threading.Lock()

def do_request():
    global thread_num
    # -------------
    # my code here
    # -------------
    with lock:
        thread_num -= 1

while True:
    if thread_num <= 50:
        with lock:
            thread_num += 1
        t = threading.Thread(target=do_request)
        t.start()
    else:
        time.sleep(0.01)

感谢所有回复。