有一阵子我被这问题困扰,其实也不是什么大问题,
比如说,100个data分给10个threads处理,平均一个thread分到10个。
但是,这data处理时间并不一致,时间有长有短,
可能有几个特别长,所以,拿到长的那个thread,可能后面还有一些data,
全等在那里,其他的thread都做完了,却不能帮忙。
目前我是用multiprocessing.Queue,100个data全丢到queue,
每个thread处理完的自己去queue拿下一个,这样比较没有浪费到时间。
不知道大家有没有其他更好的,或是现成就有我却没去用的?
因为我不确定multiprocessing.Pool是不是我要的~~