import requests
import threading
import concurrent.futures
import time
from utils import RandomNumberAPI
api = RandomNumberAPI()
def thread_function():
tokens = api.request()
return tokens
if __name__ == "__main__":
results = []
start = time.time()
with concurrent.futures.ThreadPoolExecutor() as executor:
futures = {executor.submit(thread_function) for _ in range(1000)}
for future in concurrent.futures.as_completed(futures):
result = future.result()
results.append(result)
if len(results) % 60 == 0:
time_to_wait = max(0, start + 1 - time.time())
time.sleep(time_to_wait)
start = time.time()
print(results)