diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-02-09 14:11:01 +0100 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-02-09 14:11:01 +0100 |
commit | dcf48329e291a06082e6693c6925f22b16000f3e (patch) | |
tree | 3da5c746707dd1ae1b9e3070abf7c6d2b8886992 /logserver/src | |
parent | 63a1628f1bbef54044c15f55fea518eb12e9b19a (diff) |
Sleep in end of iteration
Diffstat (limited to 'logserver/src')
-rw-r--r-- | logserver/src/main/java/com/yahoo/logserver/Flusher.java | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/logserver/src/main/java/com/yahoo/logserver/Flusher.java b/logserver/src/main/java/com/yahoo/logserver/Flusher.java index 07ecae66d90..a837f9491dc 100644 --- a/logserver/src/main/java/com/yahoo/logserver/Flusher.java +++ b/logserver/src/main/java/com/yahoo/logserver/Flusher.java @@ -1,14 +1,14 @@ // Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.logserver; +import com.yahoo.logserver.handlers.LogHandler; + import java.lang.ref.WeakReference; import java.util.ArrayList; import java.util.Iterator; import java.util.List; -import java.util.logging.Logger; - import java.util.logging.Level; -import com.yahoo.logserver.handlers.LogHandler; +import java.util.logging.Logger; /** * @author Bjorn Borud @@ -32,10 +32,10 @@ public class Flusher extends Thread { logHandlers.add(new WeakReference<>(logHandler)); } + @Override public synchronized void run() { try { while(!isInterrupted()) { - Thread.sleep(2000); Iterator<WeakReference<LogHandler>> it = logHandlers.iterator(); while (it.hasNext()) { WeakReference<LogHandler> r = it.next(); @@ -49,6 +49,7 @@ public class Flusher extends Thread { log.log(Level.FINE, "Flushing " + h); } } + Thread.sleep(2000); } } catch (InterruptedException e) { log.log(Level.WARNING, "flusher was interrupted", e); |