如何确保线程池不丢失任务?
- 加快消费速度减少任务排队,降低丢失风险;
- 利用钩子方法,当任务超时时,任务重新入队,注意重复执行的问题。
- 如果并发量不大的话,可以考虑在拒绝策略中交由主线程完成,主线程会因此降低任务提交速度,进而降低线程池负担,形成反馈环
- 如果并发量大的话,可以重写拒绝策略,将被拒绝的任务以某种形式进行持久化,随后再次处理,这也是最稳健的方案:
- 如果外部使用了MO等异步队列,会相对简单些,未能提交到线程时的任务,仍保留在MQ 中不要标记为已消费
如何确保线程池不丢失任务?
本文标题:034 如何确保线程池不丢失任务?
本文链接:https://www.haomeiwen.com/subject/njauxrtx.html
网友评论