大家好，又见面了，我是你们的朋友全栈君。
异步操作
activiti通过事务方式执行流程，可以根据你的需求定制。现在开始看一下activiti通常是如何处理事务的。 如果触发了activiti的操作(比如，开始流程，完成任务，触发流程继续执行)， activiti会推进流程，直到每个分支都进入等待状态。更抽象的说，它会流程图执行深度优先搜索， 如果每个分支都遇到等待状态，就会返回。等待状态是”稍后”需要执行任务， 就是说activiti会把当前状态保存到数据库中，然后等待下一次触发。 触发可能来自外部，比如用户任务或接收到一个消息，也可能来自activiti本身，比如我们设置了定时器事件。 下面图片展示了这种操作：
我们可以看到包含用户任务，服务任务和定时器事件的流程。完成用户任务，和校验地址是在同一个工作单元中， 所以它们的成功和失败是原子性的。意味着如果服务任务抛出异常，我们要回滚当前事务， 这样流程会退回到用户任务，用户任务就依然在数据库里。 这就是activiti默认的行为。在(1)中应用或客户端线程完成任务。这会执行服务，流程推进，直到遇到一个等待状态， 这里就是定时器(2)。然后它会返回给调用者(3)，并提交事务(如果事务是由activiti开启的)。
有的时候，这不是我们想要的。有时我们需要自己控制流程中事务的边界，这样就能把业务逻辑包裹在一起。 这就需要使用异步执行了。参考下面的流程(判断)：
这次我们完成了用户任务，生成一个发票，把发票发送给客户。 这次生成发票不在同一个工作单元内了，所以我们不想对用户任务进行回滚，如果生成发票出错了。 所以，我们想让activiti实现的是完成用户任务(1)，提交事务，返回给调用者应用。然后在后台的线程中，异步执行生成发票。 后台线程就是activiti的job执行器(其实是一个线程池)周期对数据库的job进行扫描。 所以后面的场景，当我们到达”generate invoice”任务，我们为activiti创建一个稍后执行的job”消息”， 并把它保存到数据库。 job会被job执行器获取并执行。我们也会给本地job执行器一个提醒，告诉它有一个新job，来增加性能。
要想使用这个特性，我们要使用activiti:async=”true”扩展。例子中，服务任务看起来就是这样：
activiti:async可以使用到如下bpmn任务类型中： task, serviceTask, scriptTask, businessRuleTask, sendTask, receiveTask, userTask, subProcess, callActivity
对于userTask，receiveTask和其他等待装填，异步执行的作用是让开始流程监听器运行在一个单独的线程/事务中。
发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/162654.html原文链接：https://javaforall.cn
