From f1f991c742130468f3ded3e7cf108d03bcfbb43f Mon Sep 17 00:00:00 2001 From: godotg Date: Thu, 22 Dec 2022 21:05:08 +0800 Subject: [PATCH] del[net]: remove unnecessary thread constructor parameters --- event/src/main/java/com/zfoo/event/manager/EventBus.java | 2 +- .../java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java | 2 +- net/src/main/java/com/zfoo/net/task/TaskBus.java | 2 +- .../src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java | 2 +- 4 files changed, 4 insertions(+), 4 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 6f597777..69183684 100644 --- a/event/src/main/java/com/zfoo/event/manager/EventBus.java +++ b/event/src/main/java/com/zfoo/event/manager/EventBus.java @@ -83,7 +83,7 @@ public abstract class EventBus { @Override public Thread newThread(Runnable runnable) { var threadName = StringUtils.format("event-p{}-t{}", poolNumber + 1, threadNumber.getAndIncrement()); - var thread = new FastThreadLocalThread(group, runnable, threadName, 0); + var thread = new FastThreadLocalThread(group, runnable, threadName); thread.setDaemon(false); thread.setPriority(Thread.NORM_PRIORITY); thread.setUncaughtExceptionHandler((t, e) -> logger.error(t.toString(), e)); diff --git a/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java b/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java index 15730082..7bd03aff 100644 --- a/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java +++ b/net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java @@ -93,7 +93,7 @@ public class ZookeeperRegistry implements IRegistry { @Override public Thread newThread(Runnable runnable) { - Thread t = new FastThreadLocalThread(group, runnable, namePrefix + threadNumber.getAndIncrement(), 0); + Thread t = new FastThreadLocalThread(group, runnable, namePrefix + threadNumber.getAndIncrement()); t.setDaemon(false); t.setPriority(Thread.NORM_PRIORITY); t.setUncaughtExceptionHandler((thread, e) -> logger.error(thread.toString(), e)); 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 d671b474..2ad15f9f 100644 --- a/net/src/main/java/com/zfoo/net/task/TaskBus.java +++ b/net/src/main/java/com/zfoo/net/task/TaskBus.java @@ -79,7 +79,7 @@ public final class TaskBus { @Override public Thread newThread(Runnable runnable) { var threadName = StringUtils.format("task-p{}-t{}", poolNumber + 1, threadNumber.getAndIncrement()); - var thread = new FastThreadLocalThread(group, runnable, threadName, 0); + var thread = new FastThreadLocalThread(group, runnable, threadName); thread.setDaemon(false); thread.setPriority(Thread.NORM_PRIORITY); thread.setUncaughtExceptionHandler((t, e) -> logger.error(t.toString(), e)); diff --git a/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java b/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java index 8d9d7480..754eeaa9 100644 --- a/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java +++ b/scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java @@ -85,7 +85,7 @@ public abstract class SchedulerBus { @Override public Thread newThread(Runnable runnable) { var threadName = StringUtils.format("scheduler-p{}-t{}", poolNumber, threadNumber.getAndIncrement()); - var thread = new FastThreadLocalThread(group, runnable, threadName, 0); + var thread = new FastThreadLocalThread(group, runnable, threadName); thread.setDaemon(false); thread.setPriority(Thread.NORM_PRIORITY); thread.setUncaughtExceptionHandler((t, e) -> logger.error(t.toString(), e));