Refactor comparator
This commit is contained in:
parent
73925c14dc
commit
98ec0ac0b3
@ -1,5 +1,7 @@
|
|||||||
package com.baeldung.concurrent.delayqueue;
|
package com.baeldung.concurrent.delayqueue;
|
||||||
|
|
||||||
|
import com.google.common.primitives.Ints;
|
||||||
|
|
||||||
import java.util.concurrent.Delayed;
|
import java.util.concurrent.Delayed;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
@ -20,13 +22,7 @@ public class DelayObject implements Delayed {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public int compareTo(Delayed o) {
|
public int compareTo(Delayed o) {
|
||||||
if (this.startTime < ((DelayObject) o).startTime) {
|
return Ints.saturatedCast(this.startTime - ((DelayObject) o).startTime);
|
||||||
return -1;
|
|
||||||
}
|
|
||||||
if (this.startTime > ((DelayObject) o).startTime) {
|
|
||||||
return 1;
|
|
||||||
}
|
|
||||||
return 0;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
Loading…
x
Reference in New Issue
Block a user