diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncActivityTriggerJobHandler.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncActivityTriggerJobHandler.java
index c59fe7897..7da1fd889 100644
--- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncActivityTriggerJobHandler.java
+++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/job/AsyncActivityTriggerJobHandler.java
@@ -18,7 +18,7 @@ import org.flowable.variable.api.delegate.VariableScope;
  * @since 2024-09-09 14:36
  */
 @Slf4j
-public class AsyncActivityTriggerJobHandler extends AbstractJobHandler implements JobHandler {
+public class AsyncActivityTriggerJobHandler extends AbstractExecuteWithLockJobHandler implements JobHandler {
     public static final String TYPE = "async-activity-trigger";
 
     @Override
@@ -27,7 +27,7 @@ public class AsyncActivityTriggerJobHandler extends AbstractJobHandler implement
     }
 
     @Override
-    public void execute(JobEntity job, String configuration, VariableScope variableScope, CommandContext commandContext) {
+    public void executeInternal(JobEntity job, String configuration, VariableScope variableScope, CommandContext commandContext) {
         log.info("AsyncActivityTriggerJobHandler executing...");
         ProcessEngineConfigurationImpl processEngineConfiguration =
             CommandContextUtil.getProcessEngineConfiguration(commandContext);