diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-01-27 15:40:31 +0100 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-01-27 15:40:31 +0100 |
commit | 63a449188397de600f5d2efaa6a175fe61944f22 (patch) | |
tree | b03d523903f2a423b8096c40e666852649102718 /jdisc_http_service/src | |
parent | 7c0dedd65cc37f3079544f085379b66d8df83b23 (diff) |
Use single thread with lower priority for log file compression
Diffstat (limited to 'jdisc_http_service/src')
-rw-r--r-- | jdisc_http_service/src/main/java/com/yahoo/container/logging/LogFileHandler.java | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/jdisc_http_service/src/main/java/com/yahoo/container/logging/LogFileHandler.java b/jdisc_http_service/src/main/java/com/yahoo/container/logging/LogFileHandler.java index 104c75a7b88..7839a13b0ca 100644 --- a/jdisc_http_service/src/main/java/com/yahoo/container/logging/LogFileHandler.java +++ b/jdisc_http_service/src/main/java/com/yahoo/container/logging/LogFileHandler.java @@ -2,7 +2,6 @@ package com.yahoo.container.logging; import com.yahoo.compress.ZstdOuputStream; -import com.yahoo.concurrent.ThreadFactoryFactory; import com.yahoo.io.NativeIO; import com.yahoo.log.LogFileDb; import com.yahoo.protect.Process; @@ -194,7 +193,7 @@ class LogFileHandler <LOGTYPE> { private final Compression compression; private final long[] rotationTimes; private final String symlinkName; - private final ExecutorService executor = Executors.newCachedThreadPool(ThreadFactoryFactory.getDaemonThreadFactory("logfilehandler.compression")); + private final ExecutorService executor = createCompressionTaskExecutor(); private final NativeIO nativeIO = new NativeIO(); @@ -214,6 +213,15 @@ class LogFileHandler <LOGTYPE> { this.operationProvider = operationProvider; } + private static ExecutorService createCompressionTaskExecutor() { + return Executors.newSingleThreadExecutor(runnable -> { + Thread thread = new Thread(runnable, "logfilehandler.compression"); + thread.setDaemon(true); + thread.setPriority(Thread.MIN_PRIORITY); + return thread; + }); + } + @Override public void run() { try { |