From ac7a37648bb0f5d0e676101bea9b9feac1cbc43c Mon Sep 17 00:00:00 2001
From: tangmingyou <234767776@qq.com>
Date: Tue, 12 Apr 2022 23:42:55 +0800
Subject: [PATCH] worker group

---
 .../java/net/sopod/soim/entry/worker/WorkerGroup.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/im-entry/src/main/java/net/sopod/soim/entry/worker/WorkerGroup.java b/im-entry/src/main/java/net/sopod/soim/entry/worker/WorkerGroup.java
index 790ab8a..5526e79 100644
--- a/im-entry/src/main/java/net/sopod/soim/entry/worker/WorkerGroup.java
+++ b/im-entry/src/main/java/net/sopod/soim/entry/worker/WorkerGroup.java
@@ -21,17 +21,17 @@ public class WorkerGroup {
 
     private static AtomicInteger counter;
 
-    public static void init(int codeSize) {
+    public static void init(int coreSize) {
         if (WORKERS != null) {
-            logger.warn("worker group duplicate init, current worker size {}, param size {}", WORKERS.length, codeSize);
+            logger.warn("worker group duplicate init, current worker size {}, param size {}", WORKERS.length, coreSize);
             return;
         }
-        WORKERS = new Worker[codeSize];
-        for (int i = 0; i < codeSize; i++) {
+        WORKERS = new Worker[coreSize];
+        for (int i = 0; i < coreSize; i++) {
             WORKERS[i] = new Worker("group-worker-" + i);
         }
         counter = new AtomicInteger(-1);
-        logger.info("worker group initialed, worker size {}", codeSize);
+        logger.info("worker group initialed, worker size {}", coreSize);
     }
 
     public static Worker next() {