修复BUG

laijunxiong · Aug 31, 2019 · 910c829 · 910c829
1 parent d6e9d65
commit 910c829
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/.../src/main/java/com/alibaba/jvm/sandbox/api/http/printer/ConcurrentLinkedQueuePrinter.java b/.../src/main/java/com/alibaba/jvm/sandbox/api/http/printer/ConcurrentLinkedQueuePrinter.java
@@ -7,6 +7,8 @@
 import java.util.concurrent.locks.Condition;
 import java.util.concurrent.locks.ReentrantLock;
 
+import static java.lang.Math.min;
+
 /**
  * 高性能文本输出
  * 高性能背后的代价就是相对比较高的CPU开销
@@ -110,15 +112,13 @@ private long computeDelayTimeMs() {
             return delayTimeMs;
         } else {
             final long newDelayTime = delayTimeMs + delayStepTimeMs;
-            delayTimeMs = newDelayTime < delayMaxTimeMs
-                    ? newDelayTime
-                    : delayMaxTimeMs;
+            delayTimeMs = min(newDelayTime, delayMaxTimeMs);
             return delayTimeMs;
         }
     }
 
-    private long resetDelayTimeMs() {
-        return delayTimeMs = delayStepTimeMs;
+    private void resetDelayTimeMs() {
+        delayTimeMs = delayStepTimeMs;
     }
 
     private void delay() throws InterruptedException {