대기열 모듈을 사용하면 특정 수의 항목을 보유할 수 있는 새 대기열 개체를 생성할 수 있습니다. Queue를 제어하는 방법은 다음과 같습니다 -
- get() − get()은 대기열에서 항목을 제거하고 반환합니다.
- put() − put은 항목을 대기열에 추가합니다.
- qsize() − qsize()는 현재 대기열에 있는 항목 수를 반환합니다.
- 빈() - empty()는 대기열이 비어 있으면 True를 반환합니다. 그렇지 않으면 거짓입니다.
- 전체() - full()은 대기열이 가득 차면 True를 반환합니다. 그렇지 않으면 거짓입니다.
예시
#!/usr/bin/python import Queue import threading import time exitFlag = 0 class myThread (threading.Thread): def __init__(self, threadID, name, q): threading.Thread.__init__(self) self.threadID = threadID self.name = name self.q = q def run(self): print "Starting " + self.name process_data(self.name, self.q) print "Exiting " + self.name def process_data(threadName, q): while not exitFlag: queueLock.acquire() if not workQueue.empty(): data = q.get() queueLock.release() print "%s processing %s" % (threadName, data) else: queueLock.release() time.sleep(1) threadList = ["Thread-1", "Thread-2", "Thread-3"] nameList = ["One", "Two", "Three", "Four", "Five"] queueLock = threading.Lock() workQueue = Queue.Queue(10) threads = [] threadID = 1 # Create new threads for tName in threadList: thread = myThread(threadID, tName, workQueue) thread.start() threads.append(thread) threadID += 1 # Fill the queue queueLock.acquire() for word in nameList: workQueue.put(word) queueLock.release() # Wait for queue to empty while not workQueue.empty(): pass # Notify threads it's time to exit exitFlag = 1 # Wait for all threads to complete for t in threads: t.join() print "Exiting Main Thread"
위의 코드가 실행되면 다음과 같은 결과가 생성됩니다 -
Starting Thread-1 Starting Thread-2 Starting Thread-3 Thread-1 processing One Thread-2 processing Two Thread-3 processing Three Thread-1 processing Four Thread-2 processing Five Exiting Thread-3 Exiting Thread-1 Exiting Thread-2 Exiting Main Thread