Threading и Queue непонятки в какакоде

import requests
import re
from queue import Queue, LifoQueue
import threading
 
 
class Proxy_check(object):
    def __init__(self):
        self.queue_wrt = Queue()
        self.queue_read = LifoQueue()
        self.queue_parse = Queue()
        self.check = re.compile(r'(banned)|(приостановлен)|(оступ заблокирован)|(одозрительная активность)')
 
    def read_file(self): # считываем проксики из файла и засовываем в очередь
        with open('Proxy.txt', 'r', encoding='utf-8') as read_file:
            for proxy_rd in read_file.read().split('\n'):
                if proxy_rd!='':
                    self.queue_read.put(proxy_rd.strip())
 
 
    def get_page(self,url): # кидаем на проверку и при удачном response добавляем в другую очередь(на дальнейшую проверку)
        while not self.queue_read.empty():
            proxy = self.queue_read.get()
            proxies = {'https':'https://'+str(proxy), 'http':'http://'+str(proxy)}
            try:
                page = requests.get(url, proxies=proxies, timeout=5)
            except:
                pass
            else:
                if page.status_code==200:
                    self.queue_parse.put((page.text, proxy))
                    self.parse_page()
            finally:
                self.queue_read.task_done()
 
 
    def parse_page(self):# проверяем полученную страницу на баны и тому подобное и кладем в очередь на запись
        while not self.queue_parse.empty():
            page = self.queue_parse.get()
            if not self.check.search(page[0]):
                self.queue_wrt.put(page[1])
                self.wrt_file()
            self.queue_parse.task_done()
 
 
    def wrt_file(self):# записываем в новый файл
        while not self.queue_wrt.empty():
            proxy = self.queue_wrt.get()
            with open('Proxy_GOOD.txt', 'a', encoding='utf-8') as wrt_file:
                wrt_file.write(proxy + '\n')
                print('Good Proxy: {} / {}'.format(proxy, str(self.queue_read.qsize())))
            self.queue_wrt.task_done()
 
 
 
if __name__ == '__main__':
    p = Proxy_check()
    url = 'https://www.yandex.ru/' # Например яндекс чекаем
    p.read_file()
    for i in range(500):
        i = threading.Thread(target=p.get_page, args={url})
        i.start()
    p.queue_parse.join()
    p.queue_wrt.join()
    p.queue_read.join()
    print('ГОТОВО')

#!/usr/bin/env python3
from concurrent.futures import ThreadPoolExecutor as Pool
import requests
 
THREADS_COUNT = 100
INPUT_FILE = 'Proxy.txt'
PROXY_TYPE = 'http'
PROXY_TYPE_SEP = '://'
CONFIG = {'timeout': 10, 'headers': {'User-Agent': 'bot'}, 'url': 'https://www.yandex.ru/'}
 
def prepare_requests(config):
    def wrapper(proxy):
        try:
            proxy = PROXY_TYPE_SEP.join((PROXY_TYPE, proxy))
            proxy = {'http': proxy, 'https': proxy}
            r = requests.get(proxies=proxy, **config)
            r.raise_for_status()
        except Exception as e:
            print('Error with message:', e)
            return False
        else:
            return True
    return wrapper
 
 
if __name__ == '__main__':
    session = prepare_requests(CONFIG)
    with open(INPUT_FILE, 'r') as f:
        lines = (x.strip() for x in f.readlines() if x.strip())
    
    with Pool(THREADS_COUNT) as pool:
        outlineы = tuple((x for x in pool.map(session, lines) if x))
    
    with open('good.txt', 'r') as f:
        for line in outlines:
            f.write(line)
            f.write('\n')
        f.flush()
 
    print('ГОТОВО')