perf: change apply/commit/runner fiber signalCountInEachRound to 50.

dtprj · Jun 13, 2024 · 58e9b96 · 58e9b96
1 parent b21c21c
commit 58e9b96
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/server/src/main/java/com/github/dtprj/dongting/raft/impl/ApplyManager.java b/server/src/main/java/com/github/dtprj/dongting/raft/impl/ApplyManager.java
@@ -94,7 +94,7 @@ public void init(FiberGroup fiberGroup) {
     }
 
     private void startApplyFiber(FiberGroup fiberGroup) {
-        Fiber f = new Fiber("apply", fiberGroup, new ApplyFrame());
+        Fiber f = new Fiber("apply", fiberGroup, new ApplyFrame(), false, 50);
         f.start();
     }
 

diff --git a/server/src/main/java/com/github/dtprj/dongting/raft/impl/CommitManager.java b/server/src/main/java/com/github/dtprj/dongting/raft/impl/CommitManager.java
@@ -49,7 +49,7 @@ public void postInit() {
 
     public void startCommitFiber() {
         Fiber fiber = new Fiber("commit" + raftStatus.getGroupId(), FiberGroup.currentGroup(),
-                new CommitFiberFrame(), true);
+                new CommitFiberFrame(), true, 50);
         fiber.start();
     }
 

diff --git a/server/src/main/java/com/github/dtprj/dongting/raft/impl/LinearTaskRunner.java b/server/src/main/java/com/github/dtprj/dongting/raft/impl/LinearTaskRunner.java
@@ -77,7 +77,7 @@ public void postInit() {
     public void init(FiberChannel<RaftTask> taskChannel) {
         this.taskChannel = taskChannel;
         Fiber f = new Fiber("linearTaskRunner", groupConfig.getFiberGroup(),
-                new RunnerFrame(), true, 10);
+                new RunnerFrame(), true, 50);
         f.start();
     }