diff --git a/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/RunStateHandlerTest.java b/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/RunStateHandlerTest.java
index 2793adf3..b02a3ebd 100644
--- a/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/RunStateHandlerTest.java
+++ b/hippo4j-example/src/main/java/cn/hippo4j/example/inittest/RunStateHandlerTest.java
@@ -1,12 +1,10 @@
 package cn.hippo4j.example.inittest;
 
-import cn.hippo4j.example.constant.GlobalTestConstant;
-import cn.hippo4j.starter.core.GlobalThreadPoolManage;
-import cn.hippo4j.starter.wrapper.DynamicThreadPoolWrapper;
 import cn.hutool.core.thread.ThreadUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Random;
 import java.util.concurrent.ThreadPoolExecutor;
 
@@ -20,6 +18,9 @@ import java.util.concurrent.ThreadPoolExecutor;
 @Component
 public class RunStateHandlerTest {
 
+    @Resource
+    private ThreadPoolExecutor dynamicThreadPoolExecutor;
+
     // @PostConstruct
     @SuppressWarnings("all")
     public void runStateHandlerTest() {
@@ -28,10 +29,8 @@ public class RunStateHandlerTest {
         new Thread(() -> {
             ThreadUtil.sleep(5000);
             for (int i = 0; i < Integer.MAX_VALUE; i++) {
-                DynamicThreadPoolWrapper poolWrapper = GlobalThreadPoolManage.getExecutorService(GlobalTestConstant.MESSAGE_PRODUCE);
-                ThreadPoolExecutor pool = poolWrapper.getExecutor();
                 try {
-                    pool.execute(() -> {
+                    dynamicThreadPoolExecutor.execute(() -> {
                         log.info("Thread pool name :: {}, Executing incoming blocking...", Thread.currentThread().getName());
                         try {
                             int maxRandom = 10;