diff --git a/src/org/redkale/boot/Application.java b/src/org/redkale/boot/Application.java index 8a0b68719..0c363bd65 100644 --- a/src/org/redkale/boot/Application.java +++ b/src/org/redkale/boot/Application.java @@ -305,7 +305,7 @@ public final class Application { transportExec = Executors.newFixedThreadPool(threads, (Runnable r) -> { Thread t = new Thread(r); t.setDaemon(true); - t.setName("Transport-Thread-" + counter.incrementAndGet()); + t.setName("Redkale-Transport-Thread-" + counter.incrementAndGet()); return t; }); transportGroup = AsynchronousChannelGroup.withCachedThreadPool(transportExec, 1); @@ -320,7 +320,7 @@ public final class Application { transportExec = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 8, (Runnable r) -> { Thread t = new Thread(r); t.setDaemon(true); - t.setName("Transport-Thread-" + counter.incrementAndGet()); + t.setName("Redkale-Transport-Thread-" + counter.incrementAndGet()); return t; }); try { @@ -584,7 +584,7 @@ public final class Application { final Application application = this; new Thread() { { - setName("Application-Control-Thread"); + setName("Redkale-Application-SelfServer-Thread"); } @Override @@ -755,7 +755,7 @@ public final class Application { Thread thread = new Thread() { { String host = serconf.getValue("host", "0.0.0.0").replace("0.0.0.0", "*"); - setName(serconf.getValue("protocol", "Server").toUpperCase() + "-" + host + ":" + serconf.getIntValue("port") + "-Thread"); + setName("Redkale-" + serconf.getValue("protocol", "Server").toUpperCase() + "-" + host + ":" + serconf.getIntValue("port") + "-Thread"); this.setDaemon(true); } @@ -869,6 +869,7 @@ public final class Application { public static void main(String[] args) throws Exception { Utility.midnight(); //先初始化一下Utility + Thread.currentThread().setName("Redkale-Application-Main-Thread"); //运行主程序 final Application application = Application.create(false); if (System.getProperty("CMD") != null) { diff --git a/src/org/redkale/boot/LogFileHandler.java b/src/org/redkale/boot/LogFileHandler.java index dfd203e03..de6796064 100644 --- a/src/org/redkale/boot/LogFileHandler.java +++ b/src/org/redkale/boot/LogFileHandler.java @@ -133,7 +133,7 @@ public class LogFileHandler extends Handler { } private void open() { - final String name = "Logging-" + getClass().getSimpleName() + "-Thread"; + final String name = "Redkale-Logging-" + getClass().getSimpleName() + "-Thread"; new Thread() { { setName(name); diff --git a/src/org/redkale/net/Server.java b/src/org/redkale/net/Server.java index 8e7d8c3d5..27f81ab19 100644 --- a/src/org/redkale/net/Server.java +++ b/src/org/redkale/net/Server.java @@ -153,7 +153,7 @@ public abstract class Server { Thread t = new WorkThread(executor, r); - t.setName(n + "-ServletThread-" + f.format(counter.incrementAndGet())); + t.setName("Redkale-" + n + "-ServletThread-" + f.format(counter.incrementAndGet())); return t; }); } diff --git a/src/org/redkale/net/TransportFactory.java b/src/org/redkale/net/TransportFactory.java index a334e70bc..d776b230c 100644 --- a/src/org/redkale/net/TransportFactory.java +++ b/src/org/redkale/net/TransportFactory.java @@ -119,7 +119,7 @@ public class TransportFactory { if (this.checkinterval < 2) this.checkinterval = 2; } this.scheduler = new ScheduledThreadPoolExecutor(1, (Runnable r) -> { - final Thread t = new Thread(r, this.getClass().getSimpleName() + "-TransportFactoryTask-Thread"); + final Thread t = new Thread(r, "Redkale-" + this.getClass().getSimpleName() + "-Schedule-Thread"); t.setDaemon(true); return t; }); @@ -162,7 +162,7 @@ public class TransportFactory { ExecutorService transportExec = Executors.newFixedThreadPool(threads, (Runnable r) -> { Thread t = new Thread(r); t.setDaemon(true); - t.setName("Transport-Thread-" + counter.incrementAndGet()); + t.setName("Redkale-Transport-Thread-" + counter.incrementAndGet()); return t; }); AsynchronousChannelGroup transportGroup = null; diff --git a/src/org/redkale/net/http/HttpResourceServlet.java b/src/org/redkale/net/http/HttpResourceServlet.java index c32b7cce5..41c322251 100644 --- a/src/org/redkale/net/http/HttpResourceServlet.java +++ b/src/org/redkale/net/http/HttpResourceServlet.java @@ -37,7 +37,7 @@ public class HttpResourceServlet extends HttpServlet { public WatchThread(File root) throws IOException { this.root = root; - this.setName("HttpResourceServlet-Watch-Thread"); + this.setName("Redkale-HttpResourceServlet-Watch-Thread"); this.setDaemon(true); this.watcher = this.root.toPath().getFileSystem().newWatchService(); } diff --git a/src/org/redkale/source/DataSqlSource.java b/src/org/redkale/source/DataSqlSource.java index a9eec1069..2027557b9 100644 --- a/src/org/redkale/source/DataSqlSource.java +++ b/src/org/redkale/source/DataSqlSource.java @@ -91,7 +91,7 @@ public abstract class DataSqlSource extends AbstractService implement } else if (s.length() == 2) { s = "0" + s; } - t.setName(cname + "-Thread-" + s); + t.setName("Redkale-"+cname + "-Thread-" + s); t.setUncaughtExceptionHandler(ueh); return t; });