比如说:有一群人在讲话,需要处理每个人讲的话。为了提高处理速度,将每段话多线程异步处理,但是又要保证同一个人的话按顺序处理。(即可以不保证全局顺序,但要保证局部顺序) 有什么模型可以做到?
我想的方法有两个: 1 、一个线程池,同时维护一个每个线程执行任务的信息。新的任务来了,判断是否有对应用一资源执行的任务,放在一个等待队列里。起一个定时作业,轮询是否完成。若完成放入线程池执行。 2 、起多个线程,多少个线程就起多少个队列,线程 take 队列里的 task 。拿到消息 hash 到各自队列中. 在知乎上提了个问题欢迎大家解答。 https://www.zhihu.com/question/52616271

