From 98ec0ac0b3afdad74c4f98972a5632207deb8d57 Mon Sep 17 00:00:00 2001 From: pivovarit Date: Sun, 14 May 2017 08:12:28 +0200 Subject: [PATCH] Refactor comparator --- .../baeldung/concurrent/delayqueue/DelayObject.java | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/core-java/src/main/java/com/baeldung/concurrent/delayqueue/DelayObject.java b/core-java/src/main/java/com/baeldung/concurrent/delayqueue/DelayObject.java index 6db0a66b1e..aa4ca58d6a 100644 --- a/core-java/src/main/java/com/baeldung/concurrent/delayqueue/DelayObject.java +++ b/core-java/src/main/java/com/baeldung/concurrent/delayqueue/DelayObject.java @@ -1,5 +1,7 @@ package com.baeldung.concurrent.delayqueue; +import com.google.common.primitives.Ints; + import java.util.concurrent.Delayed; import java.util.concurrent.TimeUnit; @@ -20,13 +22,7 @@ public class DelayObject implements Delayed { @Override public int compareTo(Delayed o) { - if (this.startTime < ((DelayObject) o).startTime) { - return -1; - } - if (this.startTime > ((DelayObject) o).startTime) { - return 1; - } - return 0; + return Ints.saturatedCast(this.startTime - ((DelayObject) o).startTime); } @Override