aboutsummaryrefslogtreecommitdiffstats
path: root/jdisc_http_service/src
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@verizonmedia.com>2021-01-27 15:40:31 +0100
committerBjørn Christian Seime <bjorncs@verizonmedia.com>2021-01-27 15:40:31 +0100
commit63a449188397de600f5d2efaa6a175fe61944f22 (patch)
treeb03d523903f2a423b8096c40e666852649102718 /jdisc_http_service/src
parent7c0dedd65cc37f3079544f085379b66d8df83b23 (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.java12
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 {