Fix LogStage sleep condition. (#1907)

* Fix Logstage sleep condition. * test restore
7mind · Mar 1, 2023 · 25fef9e · 25fef9e
1 parent 38a6709
commit 25fef9e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/logstage/logstage-core/.jvm/src/main/scala/izumi/logstage/sink/QueueingSink.scala b/logstage/logstage-core/.jvm/src/main/scala/izumi/logstage/sink/QueueingSink.scala
@@ -69,9 +69,9 @@ class QueueingSink(target: LogSink, sleepTime: FiniteDuration = 50.millis) exten
         try {
           // in case queue was empty we sleep a bit (it's a sane heuristic), otherwise it's better to continue working asap
           if (doFlush(maxBatchSize)) {
-            Thread.sleep(sleepTime.toMillis)
-          } else {
             Thread.`yield`()
+          } else {
+            Thread.sleep(sleepTime.toMillis)
           }
         } catch {
           case _: InterruptedException =>