Package org.apache.hadoop.hbase.regionserver.wal

Class SyncFutureCache

java.lang.Object

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

@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	Description
private static final long	SYNC_FUTURE_INVALIDATION_TIMEOUT_MINS
private final org.apache.hbase.thirdparty.com.google.common.cache.Cache<Thread,SyncFuture>	syncFutureCache

Constructor Summary

Constructors

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

Method Summary

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

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 Details

SyncFutureCache

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

Method Details

getIfPresentOrNew

public SyncFuture getIfPresentOrNew()

offer

public void offer(SyncFuture syncFuture)

Offers the sync future back to the cache for reuse.

clear

public void clear()