取代本地通过普通BlockingQueue的方式实现生产者消费者等异步场景。
请参考AsyncTaskEngineTest.java类的测试用例。
通过封装Disruptor让本地异步任务开发变得更加简单快捷,且任务执行更加高效(基于Disruptor的性能)。 通过异常重试,异常存储,异常告警等机制确保任务不丢失(100%执行成功), 详细原理介绍请访问基于Disruptor的本地异步任务执行框架原理与基本使用。
Apache License 2.0 禁止商用,个人引用请标明出处。
如果有任何疑问或者高见,欢迎添加微信公众号"Life of Coder"共同交流探讨。