java - 优先生产者消费者

Question

我目前正在研究优先工作流程用例，其中我必须实现生产者消费者逻辑。用例是 - 不同的作业集分为 3 种类型，进入阻塞队列，并且有 3 个线程或一个线程组用于消费。

队列中的作业

a1, a2, a3...an, b1,b2,b3...bn c1,c2,c3...cn, d1..., e1.....

消费者线程

CT1、CT2、CT3

我的问题是如何协调这个消费者线程或组，以便:

CT1 处理 a1-an 作业

CT2 处理 b10 亿个作业

CT3 处理 c1-cn 作业

。。。。以及用于一组新作业的更多线程。

请提供该方法的任何指示。

Answer 1

您还可以将作业分发到不同的队列，并让不同的线程或线程池在不同的队列中查找作业。

队列 a 中的作业:a1, a2, ..., an

队列 b 中的作业:b1、b2、...、bn

队列 c 中的作业:c1、c2、...、cn

...

正在执行作业的线程:CT1、CT2、CT3

CT1 正在执行队列 a 中的作业，CT2 正在执行队列 b 中的作业，CT3 正在执行队列 c 中的作业。