Channelhandler support libuv type executor

fanliang11 · Apr 11, 2024 · 49a309d · 49a309d
1 parent 483b9a0
commit 49a309d
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/Surging.Core/Surging.Core.DotNetty/DotNettyServerMessageListener.cs b/src/Surging.Core/Surging.Core.DotNetty/DotNettyServerMessageListener.cs
@@ -65,12 +65,14 @@ public async Task StartAsync(EndPoint endPoint)
             IEventLoopGroup bossGroup = new MultithreadEventLoopGroup(1);
             IEventLoopGroup workerGroup = new MultithreadEventLoopGroup();//Default eventLoopCount is Environment.ProcessorCount * 2
             var bootstrap = new ServerBootstrap();
-
+            IEventLoopGroup eventExecutor = new MultithreadEventLoopGroup();
             if (AppConfig.ServerOptions.Libuv)
             {
                 var dispatcher = new DispatcherEventLoopGroup();
                 bossGroup = dispatcher;
                 workerGroup = new WorkerEventLoopGroup(dispatcher);
+                var dispatcherExecutor = new DispatcherEventLoopGroup();
+                eventExecutor = new WorkerEventLoopGroup(dispatcherExecutor);
                 bootstrap.Channel<TcpServerChannel>();
             }
             else
@@ -79,7 +81,6 @@ public async Task StartAsync(EndPoint endPoint)
                 workerGroup = new MultithreadEventLoopGroup();
                 bootstrap.Channel<TcpServerSocketChannel>();
             }
-            var eventExecutor = new MultithreadEventLoopGroup(); 
             bootstrap
             .Option(ChannelOption.SoBacklog, AppConfig.ServerOptions.SoBacklog)
             .ChildOption(ChannelOption.Allocator, PooledByteBufferAllocator.Default)