, хотя лучше использовать queue и динамическую прогрузку - сделать iter(filehandler) и в вечном цикле до stopIteration гонять этот файлхендлер, queue же заюзать тупо как буффер и сделать его размер где-то так :threads_count*2(3) тогда потоки у тебя будут постоянно получать задачи, и можно будет сделать красивую обработку ошибок (хотя не стоять, я не туда уже поплыл, для чекера проксей это пох ибо что так что эдак это не катит именно для чекера проксей)

printLock = threading.Lock()

printLock = threading.RLock()

#Класс для записи данных в несколько файлов
class WRITER:
    
    #Атрибут инициализации
    def __init__(self):
        
        from threading import RLock
        
        self.Lock = RLock
        self.Locks = {}
        
        self.defaultencoding = "UTF-8"
        self.defaultout = u"out"
    
    #Атрибут записи одного элемента
    def write_one(self, data, id_=None, data_encoding=None):
        if id_ is None:
            id_ = self.defaultout
        if data_encoding is None:
            encoding = self.defaultencoding
        if id_ not in self.Locks:
            self.Locks[id_] = self.Lock()
        self.Locks[id_].acquire()
        with open(u"{0}.csv".format(id_).encode(self.defaultencoding), "a") as out:
            print data
            out.write("{0}\n".format(data.encode(encoding, "replace")))
        self.Locks[id_].release()
    
    #Атрибут записи последовательности
    def write_many(self, data, id_=None, data_encoding=None):
        if id_ is None:
            id_ = self.defaultout
        if data_encoding is None:
            encoding = self.defaultencoding
        if id_ not in self.Locks:
            self.Locks[id_] = self.Lock()
        self.Locks[id_].acquire()
        with open(u"{0}.csv".format(id_).encode(self.defaultencoding), "a") as out:
            for item in data:
                print item
                out.write("{0}\n".format(item.encode(encoding, "replace")))
        self.Locks[id_].release()