import requests
import sys
import re
import time
import random
import string
from concurrent.futures import ThreadPoolExecutor
import queue
import threading

url_queue = queue.Queue(maxsize=1000)
stop_event = threading.Event()
stats = {
    'generated': 0,
    'tested': 0,
    'valid': 0,
    'invalid': 0
}
stats_lock = threading.Lock()

def check_url(url):
    try:
        headers = {
           ...