org.apache.hadoop.hbase.master.cleaner

Class DirScanPool

java.lang.Object

org.apache.hadoop.hbase.master.cleaner.DirScanPool

All Implemented Interfaces:

ConfigurationObserver

@InterfaceAudience.Private
public class DirScanPool
extends Object
implements ConfigurationObserver

The thread pool used for scan directories

Field Summary

Fields

Modifier and Type	Field and Description
private int	cleanerLatch
private static org.slf4j.Logger	LOG
private ThreadPoolExecutor	pool
private boolean	reconfigNotification
private int	size

Constructor Summary

Constructors

Constructor and Description
DirScanPool(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
(package private) void	execute(Runnable runnable)
int	getSize()
private static ThreadPoolExecutor	initializePool(int size)
(package private) void	latchCountDown()
(package private) void	latchCountUp()
void	onConfigurationChange(org.apache.hadoop.conf.Configuration conf) Checks if pool can be updated.
void	shutdownNow()
(package private) void	tryUpdatePoolSize(long timeout)

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

size

private volatile int size

pool

private final ThreadPoolExecutor pool

cleanerLatch

private int cleanerLatch

reconfigNotification

private boolean reconfigNotification

Constructor Detail

DirScanPool

public DirScanPool(org.apache.hadoop.conf.Configuration conf)

Method Detail

initializePool

private static ThreadPoolExecutor initializePool(int size)

onConfigurationChange

public void onConfigurationChange(org.apache.hadoop.conf.Configuration conf)

Checks if pool can be updated. If so, mark for update later.

Specified by:

onConfigurationChange in interface ConfigurationObserver

Parameters:

conf - configuration

latchCountUp

void latchCountUp()

latchCountDown

void latchCountDown()

execute

void execute(Runnable runnable)

shutdownNow

public void shutdownNow()

tryUpdatePoolSize

void tryUpdatePoolSize(long timeout)

getSize

public int getSize()