DelayingRunner (Apache HBase 1.2.12 API)

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

java.lang.Object
- org.apache.hadoop.hbase.client.DelayingRunner<T>

All Implemented Interfaces:

Runnable
```
@InterfaceAudience.Private
public class DelayingRunner<T>
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<T>`	`actions`
`private static org.apache.commons.logging.Log`	`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<T>>> e)

Method Summary

Methods
Modifier and Type	Method and Description
`void`	`add(Map.Entry<byte[],List<Action<T>>> e)`
`MultiAction<T>`	`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.apache.commons.logging.Log LOG

sleepLock
```
private final Object sleepLock
```

triggerWake
```
private boolean triggerWake
```

sleepTime
```
private long sleepTime
```

actions
```
private MultiAction<T> actions
```

runnable
```
private Runnable runnable
```

Constructor Detail

DelayingRunner

public DelayingRunner(long sleepTime,
              Map.Entry<byte[],List<Action<T>>> 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<T>>> e)
```
- getActions
```
public MultiAction<T> getActions()
```
- getSleepTime
```
public long getSleepTime()
```

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.