org.apache.hadoop.hbase.client

Class DelayingRunner

java.lang.Object

org.apache.hadoop.hbase.client.DelayingRunner

All Implemented Interfaces:

Runnable

@InterfaceAudience.Private
public class DelayingRunner
extends Object
implements Runnable

A wrapper for a runnable for a group of actions for a single regionserver.

This can be used to build up the actions that should be taken and then

This class exists to simulate using a ScheduledExecutorService with just a regular ExecutorService and Runnables. It is used for legacy reasons in the the client; this could only be removed if we change the expectations in HTable around the pool the client is able to pass in and even if we deprecate the current APIs would require keeping this class around for the interim to bridge between the legacy ExecutorServices and the scheduled pool.

Field Summary

Fields

Modifier and Type	Field and Description
private MultiAction	actions
private static org.slf4j.Logger	LOG
private Runnable	runnable
private Object	sleepLock
private long	sleepTime
private boolean	triggerWake

Constructor Summary

Constructors

Constructor and Description
DelayingRunner(long sleepTime, Map.Entry<byte[],List<Action>> e)

Method Summary

Modifier and Type	Method and Description
void	add(Map.Entry<byte[],List<Action>> e)
MultiAction	getActions()
long	getSleepTime()
void	run()
void	setRunner(Runnable runner)
private boolean	sleep() Sleep for an expected amount of time.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

sleepLock

private final Object sleepLock

triggerWake

private boolean triggerWake

sleepTime

private long sleepTime

actions

private MultiAction actions

runnable

private Runnable runnable

Constructor Detail

DelayingRunner

public DelayingRunner(long sleepTime,
                      Map.Entry<byte[],List<Action>> e)

Method Detail

setRunner

public void setRunner(Runnable runner)

run

public void run()

Specified by:

run in interface Runnable

sleep

private boolean sleep()

Sleep for an expected amount of time.

This is nearly a copy of what the Sleeper does, but with the ability to know if you got interrupted while sleeping.

Returns:

true if the sleep completely entirely successfully, but otherwise false if the sleep was interrupted.

add

public void add(Map.Entry<byte[],List<Action>> e)

getActions

public MultiAction getActions()

getSleepTime

public long getSleepTime()