QThread 수를 제한하는 방법

Question

QtCore.QThread으로 시작하는 스레드 수를 Queue을 통해 제한 할 수 있습니까? 아래 코드는 실행 된 스레드가 시작된만큼 시작합니다.

from PyQt4 import QtCore, QtGui 
import Queue as queue 

app = QtGui.QApplication([]) 
theQueue = queue.Queue() 

class TheThread(QtCore.QThread): 
    def __init__(self, theQueue, parent=None): 
     QtCore.QThread.__init__(self, parent) 
     self.theQueue = theQueue 

    def run(self): 
     while True: 
      task = self.theQueue.get() 
      self.sleep(1) 
      self.theQueue.task_done() 

threads=[] 
for i in range(1, 3): 
    thread = TheThread(theQueue) 
    threads.append(thread) 
    thread.start() 

for i in range(len(threads)): 
    theQueue.put(i) 

Answer 1

방금 ​​대신 자신을 스레드의 목록을 만드는 실제 스레드 풀 개체를 사용하려면 사용할 수 있습니다 QThreadPool :

from PyQt4 import QtCore, QtGui 
import Queue as queue 
import time 

class Signal(QtCore.QObject): 
    sig = QtCore.pyqtSignal(int) 

class Worker(QtCore.QRunnable): 
    def __init__(self, theQueue, sig): 
     QtCore.QRunnable.__init__(self) 
     self.theQueue = theQueue 
     self.signal = sig 

    def run(self): 
     while True: 
      task = self.theQueue.get() 
      if task is None: 
       self.theQueue.task_done() 
       return 
      time.sleep(1) 
      print(task) 
      self.signal.sig.emit(int(task)) 
      self.theQueue.task_done() 

def result_callback(result): 
    print("Got {}".format(result)) 

MAX_THREADS = 2 
def launch_threads(): 
    theQueue = queue.Queue() 
    pool = QtCore.QThreadPool() 
    pool.setMaxThreadCount(MAX_THREADS) 
    for task in range(MAX_THREADS): 
     sig = Signal() 
     sig.sig.connect(result_callback) 
     pool.start(Worker(theQueue, sig)) 

    for i in range(MAX_THREADS * 6): # Sending more values than there are threads 
     theQueue.put(i) 

    # Tell the threads in the pool to finish 
    for i in range(MAX_THREADS): 
     theQueue.put(None) 

    pool.waitForDone() 
    QtCore.QTimer.singleShot(0, QtGui.QApplication.instance().exit) 

if __name__ == "__main__": 
    app = QtGui.QApplication([]) 
    QtCore.QTimer.singleShot(0, launch_threads) 
    app.exec_() 

출력 : 난

0 
1 
2 
3 
4 
5 
6 
7 
8 
9 
10 
11 
Got 0 
Got 1 
Got 2 
Got 3 
Got 4 
Got 5 
Got 6 
Got 7 
Got 8 
Got 9 
Got 10 
Got 11