Flowable 异步

Flowable是一个开源的工作流引擎，它支持流程自动化、任务管理和业务规则。在Flowable中处理异步操作是非常常见的，主要是通过以下方式：

1. **异步任务**：Flowable允许将任务标记为异步，当任务创建后不会立即分配给某个用户，而是放入一个队列中等待。当后台系统有资源处理时，再从队列中取出任务进行处理。

2. **消息驱动**：通过集成如Kafka、RabbitMQ等消息中间件，可以使用异步消息机制，使得工作流中的步骤作为消息生产者发送出去，接收者作为消息消费者进行处理，实现了真正的解耦。

3. **定时器和调度**：你可以设置任务在特定时间点或满足某些条件后才开始执行，这些都是异步操作的一部分。

4. **回调函数**：对于一些外部服务调用，Flowable支持注册回调函数，在服务响应返回后执行后续流程步骤。

使用Flowable的异步特性，可以让应用更灵活地管理复杂的业务流程，提高并发性和响应速度。

相关问题

flowable异步执行器 6.8版本，参数设置

Flowable是一个开源的工作流引擎，它支持流程自动化、任务管理和业务规则。在6.8版本中，异步执行器（AsyncExecutor）用于处理工作流中的非阻塞操作，比如邮件发送、数据库插入等耗时的操作，避免了主线程的阻塞。

在Flowable 6.8中设置异步执行器的参数主要包括以下几个方面：

1. **线程池配置**：你可以通过`flowable.bpmn.engine.async executor.threadPoolSize`属性指定并发执行的最大线程数。这将影响同时可以执行的任务量。

2. **超时配置**：`flowable.bpmn.engine.async executor.defaultWaitTimeInMillis`用于设定默认的等待时间，当任务队列满了时，新任务会等待这个时间再尝试执行。

3. **失败重试策略**：`flowable.task.retries`可用于设置任务执行失败后的自动重试次数。

4. **日志和监控**：`logging.level.org.flowable`可以调整异步执行器相关的日志级别，以便于跟踪和调试。

5. **资源隔离**：如果需要，还可以设置特定的线程池或单独的Spring ThreadPoolTaskExecutor实例来进行异步操作。

记得在项目配置文件（如application.properties或yml）中添加或修改这些参数，并确保它们与你的应用需求和资源状况相匹配。同时，你也可以在Flowable引擎启动时动态地设置这些值，通过Spring Boot的Environment或ApplicationContext。

如何在springboot配置flowable的异步执行器

在Spring Boot项目中配置Flowable（Activiti的一个分支，专注于业务流程自动化）的异步执行器通常涉及到以下几个步骤：

1. 添加依赖：首先在你的`pom.xml`或`build.gradle`文件中添加Flowable及其Spring Boot集成的依赖。例如：

   <dependency>
       <groupId>org.flowable</groupId>
       <artifactId>flowable-spring-boot-starter-process-engine</artifactId>
   </dependency>

2. 配置Spring Boot Actuator：Flowable默认使用Spring的TaskExecutor来处理异步任务。如果你需要自定义异步执行器，可以在`application.properties`或`application.yml`中设置相关配置，如：

   flowable.job-acquisition.enabled=false
   flowable.job-acquisition-type=activemq
   spring.activemq.broker-url=jms://localhost:61616
   spring.activemq.username=admin
   spring.activemq.password=password

这里配置了使用ActiveMQ作为消息队列。

3. 自定义Executor：如果想自定义一个Spring ThreadPoolTaskExecutor或者其他任务执行器，可以创建并注入到Spring容器中，然后配置到Flowable。例如：

   @Bean
   public ThreadPoolTaskExecutor customExecutor() {
       ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
       executor.setCorePoolSize(5);
       executor.setMaxPoolSize(10);
       executor.initialize();
       return executor;
   }
   
   @Autowired
   public void configureProcessEngine(ProcessEngineConfiguration processEngineConfig) {
       processEngineConfig.setAsyncExecutor(customExecutor());
   }

4. 使用异步开始流程实例：
在启动流程时，你可以选择异步的方式来启动，例如：

   RuntimeService runtimeService = processEngine.getRuntimeService();
   // 异步启动流程实例
   runtimeService.startProcessInstanceByKey("yourProcessKey", Collections.emptyMap(), true); // 第三个参数true表示异步