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.

Constructor Summary

Constructors

Modifier	Constructor and Description
private	DelayedUtil()

Method Summary

Modifier and Type	Method and Description
static int	compareDelayed(Delayed o1, Delayed o2)
static long	getRemainingTime(TimeUnit resultUnit, long timeout) Returns Time remaining as milliseconds.
private static long	getTimeout(Delayed o)
static <E extends Delayed> E	takeWithoutInterrupt(DelayQueue<E> queue, long timeout, TimeUnit timeUnit) Returns null (if an interrupt) or an instance of E; resets interrupt on calling thread.

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.

Constructor Detail

DelayedUtil

private DelayedUtil()

Method Detail

takeWithoutInterrupt

public static <E extends Delayed> E takeWithoutInterrupt(DelayQueue<E> queue,
                                                         long timeout,
                                                         TimeUnit timeUnit)

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)

getTimeout

private static long getTimeout(Delayed o)