import json

import time

from concurrent.futures import ThreadPoolExecutor, wait, ALL_COMPLETED

import requests

from Db import Db

db = Db()

url = ""

max_workers = 30

executor = ThreadPoolExecutor(max_workers=max_workers)

tasklist = []

def send(openiddic):

    openid = openiddic[0]

data = []

for d in data:

    task = executor.submit(send, ([d["wxopenid"]]))

    tasklist.append(task)

    if (len(tasklist) > max_workers):

        wait(tasklist, return_when=ALL_COMPLETED)

        tasklist.clear()

    print(d["wxopenid"])

wait(tasklist, return_when=ALL_COMPLETED)

print("succ")