Package org.apache.bookkeeper.common.util

Class SingleThreadExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

org.apache.bookkeeper.common.util.SingleThreadExecutor

All Implemented Interfaces:

Runnable, Executor, ExecutorService

public class SingleThreadExecutor
extends AbstractExecutorService
implements ExecutorService, Runnable

Implements a single thread executor that drains the queue in batches to minimize contention between threads.

Tasks are executed in a safe manner: if there are exceptions they are logged and the executor will proceed with the next tasks.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static enum	SingleThreadExecutor.State

Constructor Summary

Constructors

Constructor	Description
SingleThreadExecutor(ThreadFactory tf)
SingleThreadExecutor(ThreadFactory tf, int maxQueueCapacity, boolean rejectExecution)

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
void	execute(Runnable r)
(package private) void	executeRunnableOrList(Runnable runnable, List<Runnable> runnableList)
long	getCompletedTasksCount()
long	getFailedTasksCount()
(package private) int	getPendingTaskCount()
long	getQueuedTasksCount()
long	getRejectedTasksCount()
long	getSubmittedTasksCount()
boolean	isShutdown()
boolean	isTerminated()
void	registerMetrics(StatsLogger statsLogger)
void	run()
void	shutdown()
List<Runnable>	shutdownNow()

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

Constructor Details

SingleThreadExecutor

public SingleThreadExecutor(ThreadFactory tf)

SingleThreadExecutor

public SingleThreadExecutor(ThreadFactory tf,
 int maxQueueCapacity,
 boolean rejectExecution)

Method Details

run

public void run()

Specified by:

run in interface Runnable

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

awaitTermination

public boolean awaitTermination(long timeout,
 TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

getQueuedTasksCount

public long getQueuedTasksCount()

getSubmittedTasksCount

public long getSubmittedTasksCount()

getCompletedTasksCount

public long getCompletedTasksCount()

getRejectedTasksCount

public long getRejectedTasksCount()

getFailedTasksCount

public long getFailedTasksCount()

execute

public void execute(Runnable r)

Specified by:

execute in interface Executor

executeRunnableOrList

void executeRunnableOrList(Runnable runnable,
 List<Runnable> runnableList)

registerMetrics

public void registerMetrics(StatsLogger statsLogger)

getPendingTaskCount

int getPendingTaskCount()