cybercore-systems/cybercore-signer
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

perf(protocol): enable virtual threads for ccsp server and network io

Browse Source
This commit is contained in:
Claudecio Martins
2026-10-20 16:09:27 -03:00
parent a32ab3b7ce
commit b00f78505d
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
modules/cybercore-core/src/main/java/br/com/cybercore/signer/core/protocol/CcspServer.java
+3 -5
View File
@@ -55,6 +55,7 @@ import java.util.Set;
import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantLock;
@@ -120,11 +121,8 @@ public class CcspServer {
InetSocketAddress address = new InetSocketAddress(BIND_HOST, port); InetSocketAddress address = new InetSocketAddress(BIND_HOST, port);
httpServer = HttpServer.create(address, 50); httpServer = HttpServer.create(address, 50);
executor = Executors.newFixedThreadPool(8, r -> { ThreadFactory virtualThreadFactory = Thread.ofVirtual().name("ccsp-virtual-worker-", 0).factory();
Thread t = new Thread(r, "ccsp-http-worker"); executor = Executors.newThreadPerTaskExecutor(virtualThreadFactory);
t.setDaemon(true);
return t;
});
httpServer.setExecutor(executor); httpServer.setExecutor(executor);
// Registra endpoints do protocolo CCSP/1 // Registra endpoints do protocolo CCSP/1