验证阻塞策略-并行

策略	解释
并行	直接开干

这个策略顾名思义，就是和上一个批次的任务可以同时执行。

客户端代码

@Slf4j
@Component
public class TestConcurrency extends AbstractJobExecutor {

    @Override
    protected ExecuteResult doJobExecute(JobArgs jobArgs) {
        log.info("{}开始执行任务", Thread.currentThread().getName());
        for(int i = 1; i <= 5; i++) {
            log.info("{}执行第{}次", Thread.currentThread().getName(), i);
            ThreadUtil.sleep(60, TimeUnit.SECONDS);
        }
        log.info("{}任务执行完成", Thread.currentThread().getName());
        return ExecuteResult.success();
    }
}

页面配置

配置项	配置内容
任务名称	测试阻塞策略-覆盖-可中断
执行器名称	com.bjltd.test.TestConcurrency
阻塞策略	并行
触发类型	固定时间
间隔时长	60秒
超时时间	600秒

测试结果

测试总结

• 这个在实际应用中，一定要谨慎使用。
• 采用该策略一定要充分考虑幂等性问题。