diff --git a/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutor.java b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutor.java
new file mode 100644
index 0000000..2629d85
--- /dev/null
+++ b/src/main/java/com/example/easy/retry/job/TestAnnoJobExecutor.java
@@ -0,0 +1,28 @@
+package com.example.easy.retry.job;
+
+import com.aizuda.easy.retry.client.job.core.annotation.JobExecutor;
+import com.aizuda.easy.retry.client.job.core.dto.JobArgs;
+import com.aizuda.easy.retry.client.job.core.dto.JobContext;
+import com.aizuda.easy.retry.client.model.ExecuteResult;
+import com.aizuda.easy.retry.common.core.util.JsonUtil;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author www.byteblogs.com
+ * @date 2023-09-28 22:54:07
+ * @since 2.4.0
+ */
+@Component
+@JobExecutor(name = "testJobExecutor")
+public class TestAnnoJobExecutor {
+
+    public ExecuteResult jobExecute(JobArgs jobArgs) {
+        System.out.println(JsonUtil.toJsonString(jobArgs));
+//        try {
+//            Thread.sleep(30 * 1000);
+//        } catch (InterruptedException e) {
+//            throw new RuntimeException(e);
+//        }
+        return ExecuteResult.success("测试成功");
+    }
+}
diff --git a/src/main/java/com/example/easy/retry/job/TestJobExecutor.java b/src/main/java/com/example/easy/retry/job/TestJobExecutor.java
index 210fdaf..62c125d 100644
--- a/src/main/java/com/example/easy/retry/job/TestJobExecutor.java
+++ b/src/main/java/com/example/easy/retry/job/TestJobExecutor.java
@@ -1,9 +1,8 @@
 package com.example.easy.retry.job;
 
-import com.aizuda.easy.retry.client.job.core.annotation.JobExecutor;
-import com.aizuda.easy.retry.client.job.core.dto.JobContext;
+import com.aizuda.easy.retry.client.job.core.dto.JobArgs;
+import com.aizuda.easy.retry.client.job.core.executor.AbstractJobExecutor;
 import com.aizuda.easy.retry.client.model.ExecuteResult;
-import com.aizuda.easy.retry.common.core.util.JsonUtil;
 import org.springframework.stereotype.Component;
 
 /**
@@ -12,16 +11,10 @@ import org.springframework.stereotype.Component;
  * @since 2.4.0
  */
 @Component
-@JobExecutor(name = "testJobExecutor")
-public class TestJobExecutor {
+public class TestJobExecutor extends AbstractJobExecutor {
 
-    public ExecuteResult jobExecute(JobContext context) {
-        System.out.println(JsonUtil.toJsonString(context));
-        try {
-            Thread.sleep(30 * 1000);
-        } catch (InterruptedException e) {
-            throw new RuntimeException(e);
-        }
-        return ExecuteResult.success();
+    @Override
+    protected ExecuteResult doJobExecute(JobArgs jobArgs) {
+        return null;
     }
 }