diff --git a/src/test/java/parallel/ParWorker5.java b/src/test/java/parallel/ParWorker5.java
new file mode 100755
index 0000000..262e862
--- /dev/null
+++ b/src/test/java/parallel/ParWorker5.java
@@ -0,0 +1,53 @@
+package parallel;
+
+
+import com.jd.platform.async.callback.ICallback;
+import com.jd.platform.async.callback.IWorker;
+import com.jd.platform.async.executor.timer.SystemClock;
+import com.jd.platform.async.worker.WorkResult;
+import com.jd.platform.async.wrapper.WorkerWrapper;
+
+import java.util.Map;
+
+/**
+ * @author wuweifeng wrote on 2019-11-20.
+ */
+public class ParWorker5 implements IWorker<String, String>, ICallback<String, String> {
+    private long sleepTime = 1000;
+
+    public void setSleepTime(long sleepTime) {
+        this.sleepTime = sleepTime;
+    }
+    @Override
+    public String action(String object, Map<String, WorkerWrapper> allWrappers) {
+        try {
+            Thread.sleep(sleepTime);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+        return "result = " + SystemClock.now() + "---param = " + object + " from 3";
+    }
+
+
+    @Override
+    public String defaultValue() {
+        return "worker3--default";
+    }
+
+    @Override
+    public void begin() {
+        //System.out.println(Thread.currentThread().getName() + "- start --" + System.currentTimeMillis());
+    }
+
+    @Override
+    public void result(boolean success, String param, WorkResult<String> workResult) {
+        if (success) {
+            System.out.println("callback worker3 success--" + SystemClock.now() + "----" + workResult.getResult()
+                    + "-threadName:" +Thread.currentThread().getName());
+        } else {
+            System.err.println("callback worker3 failure--" + SystemClock.now() + "----"  + workResult.getResult()
+                    + "-threadName:" +Thread.currentThread().getName());
+        }
+    }
+
+}
diff --git a/src/test/java/parallel/ParWorker6.java b/src/test/java/parallel/ParWorker6.java
new file mode 100755
index 0000000..4aa6c71
--- /dev/null
+++ b/src/test/java/parallel/ParWorker6.java
@@ -0,0 +1,53 @@
+package parallel;
+
+
+import com.jd.platform.async.callback.ICallback;
+import com.jd.platform.async.callback.IWorker;
+import com.jd.platform.async.executor.timer.SystemClock;
+import com.jd.platform.async.worker.WorkResult;
+import com.jd.platform.async.wrapper.WorkerWrapper;
+
+import java.util.Map;
+
+/**
+ * @author wuweifeng wrote on 2019-11-20.
+ */
+public class ParWorker6 implements IWorker<String, String>, ICallback<String, String> {
+    private long sleepTime = 1000;
+
+    public void setSleepTime(long sleepTime) {
+        this.sleepTime = sleepTime;
+    }
+    @Override
+    public String action(String object, Map<String, WorkerWrapper> allWrappers) {
+        try {
+            Thread.sleep(sleepTime);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+        return "result = " + SystemClock.now() + "---param = " + object + " from 3";
+    }
+
+
+    @Override
+    public String defaultValue() {
+        return "worker3--default";
+    }
+
+    @Override
+    public void begin() {
+        //System.out.println(Thread.currentThread().getName() + "- start --" + System.currentTimeMillis());
+    }
+
+    @Override
+    public void result(boolean success, String param, WorkResult<String> workResult) {
+        if (success) {
+            System.out.println("callback worker3 success--" + SystemClock.now() + "----" + workResult.getResult()
+                    + "-threadName:" +Thread.currentThread().getName());
+        } else {
+            System.err.println("callback worker3 failure--" + SystemClock.now() + "----"  + workResult.getResult()
+                    + "-threadName:" +Thread.currentThread().getName());
+        }
+    }
+
+}
diff --git a/src/test/java/parallel/ParWorker7.java b/src/test/java/parallel/ParWorker7.java
new file mode 100755
index 0000000..2157995
--- /dev/null
+++ b/src/test/java/parallel/ParWorker7.java
@@ -0,0 +1,53 @@
+package parallel;
+
+
+import com.jd.platform.async.callback.ICallback;
+import com.jd.platform.async.callback.IWorker;
+import com.jd.platform.async.executor.timer.SystemClock;
+import com.jd.platform.async.worker.WorkResult;
+import com.jd.platform.async.wrapper.WorkerWrapper;
+
+import java.util.Map;
+
+/**
+ * @author wuweifeng wrote on 2019-11-20.
+ */
+public class ParWorker7 implements IWorker<String, String>, ICallback<String, String> {
+    private long sleepTime = 1000;
+
+    public void setSleepTime(long sleepTime) {
+        this.sleepTime = sleepTime;
+    }
+    @Override
+    public String action(String object, Map<String, WorkerWrapper> allWrappers) {
+        try {
+            Thread.sleep(sleepTime);
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }
+        return "result = " + SystemClock.now() + "---param = " + object + " from 3";
+    }
+
+
+    @Override
+    public String defaultValue() {
+        return "worker3--default";
+    }
+
+    @Override
+    public void begin() {
+        //System.out.println(Thread.currentThread().getName() + "- start --" + System.currentTimeMillis());
+    }
+
+    @Override
+    public void result(boolean success, String param, WorkResult<String> workResult) {
+        if (success) {
+            System.out.println("callback worker3 success--" + SystemClock.now() + "----" + workResult.getResult()
+                    + "-threadName:" +Thread.currentThread().getName());
+        } else {
+            System.err.println("callback worker3 failure--" + SystemClock.now() + "----"  + workResult.getResult()
+                    + "-threadName:" +Thread.currentThread().getName());
+        }
+    }
+
+}