import java.util.Set;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;
-import javax.annotation.Nullable;
+import org.eclipse.jdt.annotation.Nullable;
public final class HashedWheelTimerCloseable implements AutoCloseable, Timer {
private final Timer timer;
- private HashedWheelTimerCloseable(Timer timer) {
+ private HashedWheelTimerCloseable(final Timer timer) {
this.timer = timer;
}
@Override
- public void close() throws Exception {
+ public void close() {
stop();
}
@Override
- public Timeout newTimeout(TimerTask task, long delay, TimeUnit unit) {
+ public Timeout newTimeout(final TimerTask task, final long delay, final TimeUnit unit) {
return this.timer.newTimeout(task, delay, unit);
}
return this.timer.stop();
}
- public static HashedWheelTimerCloseable newInstance(@Nullable ThreadFactory threadFactory,
- @Nullable Long duration, @Nullable Integer ticksPerWheel) {
+ public static HashedWheelTimerCloseable newInstance(final @Nullable Long duration,
+ final @Nullable Integer ticksPerWheel) {
+ return newInstance(null, duration, ticksPerWheel);
+ }
+
+ public static HashedWheelTimerCloseable newInstance(final @Nullable ThreadFactory threadFactory,
+ final @Nullable Long duration, final @Nullable Integer ticksPerWheel) {
TimeUnit unit = TimeUnit.MILLISECONDS;
- if(!nullOrNonZero(duration) && threadFactory == null && nullOrNonZero(ticksPerWheel)) {
+ if(!nullOrNonPositive(duration) && threadFactory == null && nullOrNonPositive(ticksPerWheel)) {
return new HashedWheelTimerCloseable(new HashedWheelTimer(duration, unit));
}
- if(!nullOrNonZero(duration) && threadFactory == null && !nullOrNonZero(ticksPerWheel)) {
+ if(!nullOrNonPositive(duration) && threadFactory == null && !nullOrNonPositive(ticksPerWheel)) {
return new HashedWheelTimerCloseable(new HashedWheelTimer(duration, unit, ticksPerWheel));
}
- if(nullOrNonZero(duration) && threadFactory != null && nullOrNonZero(ticksPerWheel)) {
+ if(nullOrNonPositive(duration) && threadFactory != null && nullOrNonPositive(ticksPerWheel)) {
return new HashedWheelTimerCloseable(new HashedWheelTimer(threadFactory));
}
- if(!nullOrNonZero(duration) && threadFactory != null && nullOrNonZero(ticksPerWheel)) {
+ if(!nullOrNonPositive(duration) && threadFactory != null && nullOrNonPositive(ticksPerWheel)) {
return new HashedWheelTimerCloseable(
new HashedWheelTimer(threadFactory, duration, unit));
}
- if(!nullOrNonZero(duration) && threadFactory != null && !nullOrNonZero(ticksPerWheel)) {
+ if(!nullOrNonPositive(duration) && threadFactory != null && !nullOrNonPositive(ticksPerWheel)) {
return new HashedWheelTimerCloseable(
new HashedWheelTimer(threadFactory, duration, unit, ticksPerWheel));
}
return new HashedWheelTimerCloseable(new HashedWheelTimer());
}
- private static boolean nullOrNonZero(Number n) {
+ private static boolean nullOrNonPositive(final Number n) {
return n == null || n.longValue() <= 0;
}
-}
\ No newline at end of file
+}