diff --git a/riis-system/src/main/java/com/yfd/platform/component/nettyudpserver/NettyUdpRunner.java b/riis-system/src/main/java/com/yfd/platform/component/nettyudpserver/NettyUdpRunner.java
index 31c86fc..b8fde1e 100644
--- a/riis-system/src/main/java/com/yfd/platform/component/nettyudpserver/NettyUdpRunner.java
+++ b/riis-system/src/main/java/com/yfd/platform/component/nettyudpserver/NettyUdpRunner.java
@@ -1,6 +1,8 @@
 package com.yfd.platform.component.nettyudpserver;
 
 
+import com.yfd.platform.component.nettyserver.NettyServer;
+import com.yfd.platform.utils.ExecutionJob;
 import io.netty.channel.Channel;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -15,8 +17,8 @@ public class NettyUdpRunner implements CommandLineRunner {
 
     @Override
     public void run(String... args) throws Exception {
-
-        new Thread(() -> {
+        
+        ExecutionJob.EXECUTOR.submit(() -> {
             NettyUdpServer server = null;
             try {
                 server = new NettyUdpServer(9300);
@@ -24,14 +26,14 @@ public class NettyUdpRunner implements CommandLineRunner {
                 logger.info("NettyUdpRunner running");
                 channel.closeFuture().sync();
             } catch (Exception e) {
-                logger.error(e.getMessage());;
+                logger.error(e.getMessage());
+                ;
             } finally {
-                if(server!=null){
+                if (server != null) {
                     server.stop();
                 }
             }
-        }
-        ).start();
+        });
     }