tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-06-09 06:15:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

del[net]: remove unnecessary thread constructor parameters

Browse Source
This commit is contained in:
godotg
2022-12-22 21:05:08 +08:00
parent 2df2f31e62
commit f1f991c742
4 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
event/src/main/java/com/zfoo/event/manager/EventBus.java
+1 -1
View File
@@ -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));
net/src/main/java/com/zfoo/net/consumer/registry/ZookeeperRegistry.java
+1 -1
View File
@@ -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));
net/src/main/java/com/zfoo/net/task/TaskBus.java
+1 -1
View File
@@ -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));
scheduler/src/main/java/com/zfoo/scheduler/manager/SchedulerBus.java
+1 -1
View File
@@ -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));