org.apache.hadoop.hbase.regionserver.wal

Class SyncFutureCache

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.SyncFutureCache

@InterfaceAudience.Private
public final class SyncFutureCache
extends Object

A cache of SyncFutures. This class supports two methods getIfPresentOrNew() and offer(SyncFuture). Usage pattern: SyncFuture sf = syncFutureCache.getIfPresentOrNew(); sf.reset(...); // Use the sync future finally: syncFutureCache.offer(sf); Offering the sync future back to the cache makes it eligible for reuse within the same thread context. Cache keyed by the accessing thread instance and automatically invalidated if it remains unused for SYNC_FUTURE_INVALIDATION_TIMEOUT_MINS minutes.

Field Summary

Fields

Modifier and Type	Field and Description
private static long	SYNC_FUTURE_INVALIDATION_TIMEOUT_MINS
private org.apache.hbase.thirdparty.com.google.common.cache.Cache<Thread,SyncFuture>	syncFutureCache

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	clear()
SyncFuture	getIfPresentOrNew()
void	offer(SyncFuture syncFuture) Offers the sync future back to the cache for reuse.

Methods inherited from class java.lang.Object

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

Field Detail

SYNC_FUTURE_INVALIDATION_TIMEOUT_MINS

private static final long SYNC_FUTURE_INVALIDATION_TIMEOUT_MINS

See Also:

Constant Field Values

syncFutureCache

private final org.apache.hbase.thirdparty.com.google.common.cache.Cache<Thread,SyncFuture> syncFutureCache

Constructor Detail

SyncFutureCache

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

Method Detail

getIfPresentOrNew

public SyncFuture getIfPresentOrNew()

offer

public void offer(SyncFuture syncFuture)

Offers the sync future back to the cache for reuse.

clear

public void clear()