org.apache.hadoop.hbase.procedure2.util

Class DelayedUtil

java.lang.Object

org.apache.hadoop.hbase.procedure2.util.DelayedUtil

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public final class DelayedUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DelayedUtil.DelayedContainer<T>
static class	DelayedUtil.DelayedContainerWithTimestamp<T> Has a timeout.
static class	DelayedUtil.DelayedObject
static interface	DelayedUtil.DelayedWithTimeout Add a timeout to a Delay

Field Summary

Fields

Modifier and Type	Field and Description
static DelayedUtil.DelayedWithTimeout	DELAYED_POISON POISON implementation; used to mark special state: e.g.

Method Summary

Modifier and Type	Method and Description
static int	compareDelayed(Delayed o1, Delayed o2)
static long	getRemainingTime(TimeUnit resultUnit, long timeout)
static <E extends Delayed> E	takeWithoutInterrupt(DelayQueue<E> queue)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DELAYED_POISON

public static final DelayedUtil.DelayedWithTimeout DELAYED_POISON

POISON implementation; used to mark special state: e.g. shutdown.

Method Detail

takeWithoutInterrupt

public static <E extends Delayed> E takeWithoutInterrupt(DelayQueue<E> queue)

Returns:

null (if an interrupt) or an instance of E; resets interrupt on calling thread.

getRemainingTime

public static long getRemainingTime(TimeUnit resultUnit,
                                    long timeout)

Returns:

Time remaining as milliseconds.

compareDelayed

public static int compareDelayed(Delayed o1,
                                 Delayed o2)