有一陣子我被這問題困擾,其實也不是什麼大問題,
比如說,100個data分給10個threads處理,平均一個thread分到10個。
但是,這data處理時間並不一致,時間有長有短,
可能有幾個特別長,所以,拿到長的那個thread,可能後面還有一些data,
全等在那裡,其他的thread都做完了,卻不能幫忙。
目前我是用multiprocessing.Queue,100個data全丟到queue,
每個thread處理完的自己去queue拿下一個,這樣比較沒有浪費到時間。
不知道大家有沒有其他更好的,或是現成就有我卻沒去用的?
因為我不確定multiprocessing.Pool是不是我要的~~