Better thread names. Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/dbbeb5cf Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/dbbeb5cf Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/dbbeb5cf
Branch: refs/heads/LOG4J2-1349-gcfree-threadcontext Commit: dbbeb5cf505ae4adbbcd8f10d5396f5d674e7468 Parents: 21cc981 Author: ggregory <ggreg...@apache.org> Authored: Sun Sep 4 02:43:38 2016 -0400 Committer: ggregory <ggreg...@apache.org> Committed: Sun Sep 4 02:43:38 2016 -0400 ---------------------------------------------------------------------- .../java/org/apache/logging/log4j/core/appender/AsyncAppender.java | 2 +- .../main/java/org/apache/logging/log4j/core/util/CachedClock.java | 2 +- .../java/org/apache/logging/log4j/core/util/CoarseCachedClock.java | 2 +- .../logging/log4j/flume/appender/FlumePersistentManager.java | 1 + 4 files changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/dbbeb5cf/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java index 7b6e985..11ac79d 100644 --- a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java +++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java @@ -269,10 +269,10 @@ public final class AsyncAppender extends AbstractAppender { private final BlockingQueue<LogEvent> queue; public AsyncThread(final List<AppenderControl> appenders, final BlockingQueue<LogEvent> queue) { + super("AsyncAppender-" + THREAD_SEQUENCE.getAndIncrement()); this.appenders = appenders; this.queue = queue; setDaemon(true); - setName("AsyncAppenderThread" + THREAD_SEQUENCE.getAndIncrement()); } @Override http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/dbbeb5cf/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CachedClock.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CachedClock.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CachedClock.java index d53b2c0..f6d51ab 100644 --- a/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CachedClock.java +++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CachedClock.java @@ -45,7 +45,7 @@ public final class CachedClock implements Clock { LockSupport.parkNanos(1000 * 1000); } } - }, "Clock Updater Thread"); + }, "CachedClock Updater Thread"); updater.setDaemon(true); updater.start(); } http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/dbbeb5cf/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CoarseCachedClock.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CoarseCachedClock.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CoarseCachedClock.java index 769db08..144f470 100644 --- a/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CoarseCachedClock.java +++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/util/CoarseCachedClock.java @@ -28,7 +28,7 @@ public final class CoarseCachedClock implements Clock { // ignore IDE complaints; volatile long is fine private volatile long millis = System.currentTimeMillis(); - private final Thread updater = new Log4jThread("Clock Updater Thread") { + private final Thread updater = new Log4jThread("CoarseCachedClock Updater Thread") { @Override public void run() { while (true) { http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/dbbeb5cf/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java ---------------------------------------------------------------------- diff --git a/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java b/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java index 9442abe..bc591c2 100644 --- a/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java +++ b/log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumePersistentManager.java @@ -490,6 +490,7 @@ public class FlumePersistentManager extends FlumeAvroManager { public WriterThread(final Database database, final Environment environment, final FlumePersistentManager manager, final Gate gate, final int batchsize, final SecretKey secretKey, final AtomicLong dbCount, final int lockTimeoutRetryCount) { + super("FlumePersistentManager-Writer"); this.database = database; this.environment = environment; this.manager = manager;
