Управление потоками

import threading
import queue
q=queue.Queue()
threads_count=5
 
def get_city_parameters(driver):
     for city in cities_all:
         ....
         q.put(subject)
 
def main_threading():
    driver = init_driver()
    get_city_parameters(driver)
    driver.quit()
 
def starting_threading():
    while  q.empty()==False:
        if(threading.active_count()<=threads_count+1):
            t = threading.Thread(target=parsing, args=(q,))
            t.start()
 
def parsing(q):
    #print('Запуск потока', q.get()[0], q.get()[1], q.get()[2])
    print('Запуск потока', q.get())
    print("Количество активных потоков",threading.activeCount())
    driver=init_driver()
    driver.get(url_main)
    driver.quit()
 
if __name__ == '__main__':
    start_time=time.time()
    main_thread = threading.Thread(target=parsing, args=(q,))
    main_thread.start()  
    print(time.time()-start_time)

if __name__ == '__main__':
    start_time=time.time()
    main_thread = threading.Thread(target=main_threading, args=' ')
    main_thread.start()  
    print(time.time()-start_time)

from concurrent.futures import ThreadPoolExecutor, as_completed
from time import sleep, time
 
MAX_WORKERS = 10
TASK_COUNT = 25
 
def run_task(name, value):
    sleep(1)
    return name, value // 5
 
if __name__ == '__main__':
    tasks = { f'task{i}': i for i in range(TASK_COUNT) }
 
start = time()
with ThreadPoolExecutor(max_workers=MAX_WORKERS) as executor:
    workers = [executor.submit(run_task, n, v) for n, v in tasks.items()]
    for worker in as_completed(workers):
        task, res = worker.result()
        elapsed = time() - start
        print(f'+{elapsed:.2f}: {task} {res}')

from threading import Lock
from concurrent.futures import ThreadPoolExecutor, as_completed, wait
from time import sleep, time
 
MAX_WORKERS = 5
TASK_COUNT = 35
 
def msg(text):
    if not hasattr(msg, 'lock'):
        msg.lock = Lock()
    with msg.lock:
        print(text)
 
def run_task(name, value):
    sleep(2)
    return name, value // 5
 
def task_complete(task):
    name, res = task.result()
    elapsed = time() - start
    msg(f'+{elapsed:.2f}: {name} {res}')
 
 
if __name__ == '__main__':
    start = time()
    executor = ThreadPoolExecutor(max_workers=MAX_WORKERS)
    workers = []
 
    msg('creating tasks...')
    for i in range(TASK_COUNT):
        t = executor.submit(run_task, f'task{i}', i)
        t.add_done_callback(task_complete)
        workers.append(t)
        sleep(0.2)
    msg('done creating tasks')
    wait(workers)
    msg('done executing tasks')