import Queue

class Worker(QThread):
    def __init__(self, queue):
        QThread.__init__(self)
        self.queue = queue
        
    def run(self):
        while True:
            task = self.queue.get()
            result = task()
            self.emit(SIGNAL('taskDone(PyQt_PyObject)'), result)
            


class Task(object):
    def __init__(self, data):
        self.data = data
        
    def __call__(self):
        # обрабатываем данные и возвращаем результат
        return new_data
   
NUM_THREADS = 4
         
class Main(object):
    def __init__(self):
        # очередь для заданий
        self.queue = Queue.Queue()
        # создаем пул потоков
        self.threads = []
        for i in range(NUM_THREADS):
            t = Worker(self.queue)
            QObject.connect(t, SIGNAL('taskDone(PyQt_PyObject)'), self.task_done)
            self.threads.append(t)
            t.start()
            
            
        def start(self):
            # обращаемся к UI и забираем данные
            array = self.getArrayOfData()
            # в цикле создаем задания и добавляем в очередь
            for data in array:
                task = Task(data)
                self.queue.put(task)
        
        def task_done(self, result):
            # данный метод будет вызван в главном потоке, поэтому
            # можно без проблем обновлять UI
            # писать в файлы также лучше здесь, ибо отпадает необходимость
            # синхронизации потоков
            pass