python_sse長連接壓測

from threadpool import ThreadPool, makeRequests
from sseclient import SSEClient
import time


def connect(a):
    time.sleep(a % 1)
    # sse長連接請求結果，將實時打印返回的數據響應
    messages = SSEClient('url')
    for msg in messages:
        if msg == "":
            print("返回數據為空")
        else:
            print(msg)


if __name__ == "__main__":
    # 設置並發連接數
    pool = ThreadPool(100)
    test = list()
    for i in range(100):
        test.append(i)
    result = makeRequests(connect, test)
    [pool.putRequest(req) for req in result]
    pool.wait()