Package org.apache.hadoop.hbase.procedure2.util

Class DelayedUtil

java.lang.Object

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

@Private
@Evolving
public final class DelayedUtil
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	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	Description
static final DelayedUtil.DelayedWithTimeout	DELAYED_POISON	POISON implementation; used to mark special state: e.g.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	DelayedUtil()

Method Summary

Modifier and Type	Method	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 Details

DELAYED_POISON

public static final DelayedUtil.DelayedWithTimeout DELAYED_POISON

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

Constructor Details

DelayedUtil

private DelayedUtil()

Method Details

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)