From 0e4c66dbe5b7376e4ed377fc2421130cf97765fd Mon Sep 17 00:00:00 2001 From: godotg Date: Sat, 6 Jan 2024 16:16:07 +0800 Subject: [PATCH] chore[field]: field visibility --- event/src/main/java/com/zfoo/event/manager/EventBus.java | 2 +- net/src/main/java/com/zfoo/net/task/TaskBus.java | 2 +- net/src/test/java/com/zfoo/net/router/SignalBridgeTest.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/event/src/main/java/com/zfoo/event/manager/EventBus.java b/event/src/main/java/com/zfoo/event/manager/EventBus.java index e2fc0f44..27881ee2 100644 --- a/event/src/main/java/com/zfoo/event/manager/EventBus.java +++ b/event/src/main/java/com/zfoo/event/manager/EventBus.java @@ -45,7 +45,7 @@ public abstract class EventBus { * EN: The size of the thread pool. Event's thread pool is often used to do time-consuming operations, so set it a little bigger * CN: 线程池的大小. event的线程池经常用来做一些耗时的操作,所以要设置大一点 */ - public static final int EXECUTORS_SIZE = Runtime.getRuntime().availableProcessors() * 2; + private static final int EXECUTORS_SIZE = Runtime.getRuntime().availableProcessors() * 2; private static final ExecutorService[] executors = new ExecutorService[EXECUTORS_SIZE]; diff --git a/net/src/main/java/com/zfoo/net/task/TaskBus.java b/net/src/main/java/com/zfoo/net/task/TaskBus.java index 89ae60e7..417b2d37 100644 --- a/net/src/main/java/com/zfoo/net/task/TaskBus.java +++ b/net/src/main/java/com/zfoo/net/task/TaskBus.java @@ -44,7 +44,7 @@ public final class TaskBus { // EN: The size of the thread pool can also be specified through the provider thread configuration // CN: 线程池的大小,也可以通过provider thread配置指定 - public static final int EXECUTOR_SIZE; + private static final int EXECUTOR_SIZE; /** * EN: Use different thread pools to achieve isolation between thread pools without affecting each other diff --git a/net/src/test/java/com/zfoo/net/router/SignalBridgeTest.java b/net/src/test/java/com/zfoo/net/router/SignalBridgeTest.java index 850a43b9..dedb4024 100644 --- a/net/src/test/java/com/zfoo/net/router/SignalBridgeTest.java +++ b/net/src/test/java/com/zfoo/net/router/SignalBridgeTest.java @@ -27,7 +27,7 @@ import java.util.concurrent.CountDownLatch; @Ignore public class SignalBridgeTest { - private final int executorSize = EventBus.EXECUTORS_SIZE; + private final int executorSize = Runtime.getRuntime().availableProcessors() * 2; private final int count = 100_0000; private final int totalIndex = 10;