Package org.rocksdb

Class ConcurrentTaskLimiterImpl

java.lang.Object

org.rocksdb.AbstractNativeReference

org.rocksdb.AbstractImmutableNativeReference

org.rocksdb.RocksObject

org.rocksdb.ConcurrentTaskLimiter

org.rocksdb.ConcurrentTaskLimiterImpl

All Implemented Interfaces:

AutoCloseable

public class ConcurrentTaskLimiterImpl
extends ConcurrentTaskLimiter

Field Summary

Fields inherited from class org.rocksdb.RocksObject

nativeHandle_

Fields inherited from class org.rocksdb.AbstractImmutableNativeReference

owningHandle_

Constructor Summary

Constructors

Constructor	Description
ConcurrentTaskLimiterImpl(String name, int maxOutstandingTask)

Method Summary

Modifier and Type	Method	Description
protected final void	disposeInternal(long handle)
String	name()	Returns a name that identifies this concurrent task limiter.
int	outstandingTask()	Returns current outstanding task count.
ConcurrentTaskLimiter	resetMaxOutstandingTask()	Reset to unlimited max concurrent task.
ConcurrentTaskLimiter	setMaxOutstandingTask(int maxOutstandingTask)	Set max concurrent tasks. limit = 0 means no new task allowed. limit < 0 means no limitation.

Methods inherited from class org.rocksdb.RocksObject

disposeInternal, getNativeHandle

Methods inherited from class org.rocksdb.AbstractImmutableNativeReference

close, disOwnNativeHandle, isOwningHandle

Methods inherited from class java.lang.Object

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

Constructor Details

ConcurrentTaskLimiterImpl

public ConcurrentTaskLimiterImpl(String name,
 int maxOutstandingTask)

Method Details

name

public String name()

Description copied from class: ConcurrentTaskLimiter

Returns a name that identifies this concurrent task limiter.

Specified by:

name in class ConcurrentTaskLimiter

Returns:

Concurrent task limiter name.

setMaxOutstandingTask

public ConcurrentTaskLimiter setMaxOutstandingTask(int maxOutstandingTask)

Description copied from class: ConcurrentTaskLimiter

Set max concurrent tasks.
limit = 0 means no new task allowed.
limit < 0 means no limitation.

Specified by:

setMaxOutstandingTask in class ConcurrentTaskLimiter

Parameters:

maxOutstandingTask - max concurrent tasks.

Returns:

the reference to the current instance of ConcurrentTaskLimiter.

resetMaxOutstandingTask

public ConcurrentTaskLimiter resetMaxOutstandingTask()

Description copied from class: ConcurrentTaskLimiter

Reset to unlimited max concurrent task.

Specified by:

resetMaxOutstandingTask in class ConcurrentTaskLimiter

Returns:

the reference to the current instance of ConcurrentTaskLimiter.

outstandingTask

public int outstandingTask()

Description copied from class: ConcurrentTaskLimiter

Returns current outstanding task count.

Specified by:

outstandingTask in class ConcurrentTaskLimiter

Returns:

current outstanding task count.

disposeInternal

protected final void disposeInternal(long handle)

Specified by:

disposeInternal in class RocksObject