From dcf48329e291a06082e6693c6925f22b16000f3e Mon Sep 17 00:00:00 2001 From: Bjørn Christian Seime Date: Tue, 9 Feb 2021 14:11:01 +0100 Subject: Sleep in end of iteration --- logserver/src/main/java/com/yahoo/logserver/Flusher.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'logserver/src') 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> it = logHandlers.iterator(); while (it.hasNext()) { WeakReference 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); -- cgit v1.2.3