异步任务状态机有啥好的解决方案吗？

[frank1256]

rt

背景：删除耗时的资源，状态机有：删除中，删除成功，删除失败。（创建功能一样，就是创建中，创建成功、创建失败）

api 调用时，前端可以发起批量动作，例如批量删除耗时资源。我的流程就是数据库批量数据更新为删除中，然后起多个线程去异步调用真实的耗时接口。直接返回前端操作成功。异步完成后会更新数据库状态为删除成功

异常处理： 由于都是在内存中，如果服务重启，即无法知道结果。目前解决方案是每次启动之前都捞出“XX 中”的状态任务，先调查询结果接口，进行数据库更新，或者重新发起。

疑问： 目前有很多这种异步耗时又有状态的资源。我想着给他们抽象出来做成统一，有啥方案或者目前有什么开源的任务调度能解决状态机的东西吗？

[lolizeppelin]

https://wiki.openstack.org/wiki/TaskFlow

[zmal]

这不是典型的发布 /订阅场景吗...如果不想用外部 MQ ，可以用 guava 的 EventBus 类似的东西，EventBus 支持异步。

[tedzhou1221]

用个定时调度应该可以了吧，例如 xxl-job 之类 的。