咸鱼engineer之 -java多线程实现生产者消费者模式
最近小编在写一个类似这样的题目:
实现一个生产者、消费者场景。假设现在有一个任务调度系统负责处理数据A线程负责从DB里拉待处理的任务放到队列;B线程组负责从队列中处理任务;由于任务处理量较大,
所以B线程会将任务进行拆分子线程并行处理。当所有子线程处理完成后,由B线程汇总结果
我这边的想法是用多线程实现一个阻塞队列:我们直接上代码:
生产者部分:
消费者部分:
ok 写一个测试看下结果:
以上就是小编写的代码,如果有不一样的意见可以留言鸭~~~