Переопределение run() в классе, наследованном от threading.Thread (Producer-Consumer pattern)

import threading
import queue
from collections import deque
 
def getpages(): #Получаем данные
    with open(file,'r') as mfile:
        return [(URL % REQ) % int(line.strip()) for line in mfile]
def foo1(data):
   #Код
    return processed_data
 
def foo2(item):
      #Код
 
#Создаём очереди
q1=queue.Queue()
q1.queue=deque(getpages('members.csv'))
BUF_SIZE = 40
q2 = queue.Queue(BUF_SIZE)
 
#Паттерн
class ProducerThread(threading.Thread):
    def __init__(self, group=None, target=None, name = None, args=(), kwargs=None, verbose=None):
        super(ProducerThread,self).__init__()
        self.target = target
        self.name = name
 
    def run(self):
        while not q1.empty():
            if not q2.full():
                item = q1.get()
                #нечто
                q2.put(#результат работы foo1)
        return
 
class ConsumerThread(threading.Thread):
    def __init__(self, group=None, target=None, name = None, args=(), kwargs=None, verbose=None):
        super(ConsumerThread,self).__init__()
        self.target = target
        self.name = name
        return
 
    def run(self):
        while True:
            if not q2.empty():
                item=q2.get()
               #target=foo2(item), как-то так
            elif q1.empty():
                break
        return
#
#
#остальной код
#
#
if __name__ == "__main__":
    producers=[]
    for i in range(10):
        producer=ProducerThread(name = 'Producer '+ str(i), target=foo1)
        producers.append(producer)
        producer.start()
    consumers=[]
    for i in range(100):
        consumer=ConsumerThread(name = 'Consumer ' +str(i),target=foo2)
        consumers.append(consumer)
        consumer.start()
    for p in producers:
        p.join()
    for c in consumers:
        c.join()