From e430e17dc6d34138114b6bfdd099acb0f9a509e4 Mon Sep 17 00:00:00 2001 From: Hellblazer Date: Sat, 8 Jun 2024 09:38:10 -0700 Subject: [PATCH] set executor --- .../com/salesforce/apollo/model/ProcessContainerDomain.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/model/src/main/java/com/salesforce/apollo/model/ProcessContainerDomain.java b/model/src/main/java/com/salesforce/apollo/model/ProcessContainerDomain.java index 602b910a8..c486f72fe 100644 --- a/model/src/main/java/com/salesforce/apollo/model/ProcessContainerDomain.java +++ b/model/src/main/java/com/salesforce/apollo/model/ProcessContainerDomain.java @@ -84,6 +84,7 @@ public ProcessContainerDomain(Digest group, ControlledIdentifierMember member, P .protocolNegotiator( new DomainSocketNegotiatorHandler.DomainSocketNegotiator( IMPL)) + .executor(Executors.newVirtualThreadPerTaskExecutor()) .withChildOption(ChannelOption.TCP_NODELAY, true) .channelType(IMPL.getServerDomainSocketChannelClass()) .workerEventLoopGroup(portalEventLoopGroup) @@ -93,6 +94,7 @@ public ProcessContainerDomain(Digest group, ControlledIdentifierMember member, P outerContextEndpoint = new DomainSocketAddress( communicationsDirectory.resolve(UUID.randomUUID().toString()).toFile()); outerContextService = NettyServerBuilder.forAddress(outerContextEndpoint) + .executor(Executors.newVirtualThreadPerTaskExecutor()) .protocolNegotiator( new DomainSocketNegotiatorHandler.DomainSocketNegotiator(IMPL)) .withChildOption(ChannelOption.TCP_NODELAY, true)