import threading
import queue
import time
'''
queue.qsize() 返回隊列的大小
queue.empty() 如果隊列為空，返回True,反之False
queue.full() 如果隊列滿了，返回True,反之False
queue.full 與 maxsize 大小對應
queue.get([block[, timeout]])獲取隊列，timeout等待時間
queue.get_nowait() 相當queue.get(False)
queue.put(item) 寫入隊列，timeout等待時間
queue.put_nowait(item) 相當queue.put(item, False)
queue.task_done() 在完成一項工作之后，queue.task_done()函數向任務已經完成的隊列發送一個信號
'''
class CustomThread(threading.Thread):
    def __init__(self, queue):
        threading.Thread.__init__(self)
        self.__queue = queue

    def run(self):
        q_method, kwargs = self.__queue.get()
        q_method(**kwargs)
        self.__queue.task_done()

def start_thread(request_queue):
    # 啟動線程
    for i in range(request_queue.maxsize):
        t = CustomThread(request_queue)
        t.setDaemon(True)
        t.start()

def test(id):
    print("test start by id:{}".format(id))
    time.sleep(1)
    print("test end by id:{}\n".format(id))

if __name__ == '__main__':
    QUEUE_SIZE = 5
    test_queue = queue.Queue(QUEUE_SIZE)
    #啟動線程
    start_thread(test_queue)
    # 啟動線程
    # for i in range(test_queue.maxsize):
    #     t = CustomThread(test_queue)
    #     t.setDaemon(True)
    #     t.start()

    for i in range(5):
        test_queue.put((test, {"id":i}))
    #等待所有線程執行完
    test_queue.join()
    print("進程結束!")