org.apache.drill.common

Class SerializedExecutor

java.lang.Object

org.apache.drill.common.SerializedExecutor

All Implemented Interfaces:

Executor

public abstract class SerializedExecutor
extends Object
implements Executor

Serializes execution of multiple submissions to a single target, while still using a thread pool to execute those submissions. Provides an implicit queueing capability for a single target that requires any commands that execute against it to be serialized.

Constructor Summary

Constructors

Constructor and Description
SerializedExecutor(String name, Executor underlyingExecutor) Constructor.

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable command)
protected abstract void	runException(Runnable command, Throwable t) An exception occurred in the last command executed; this reports that to the subclass of SerializedExecutor.

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializedExecutor

public SerializedExecutor(String name,
                          Executor underlyingExecutor)

Constructor.

Parameters:

underlyingExecutor - underlying executor to use to execute commands submitted to this SerializedExecutor

Method Detail

runException

protected abstract void runException(Runnable command,
                                     Throwable t)

An exception occurred in the last command executed; this reports that to the subclass of SerializedExecutor.

The default implementation of this method throws an exception, which is considered an error (see below). Implementors have two alternatives: Arrange not to throw from your commands' run(), or if they do, provide an override of this method that handles any exception that is thrown.

It is an error for this to throw an exception, and doing so will terminate the thread with an IllegalStateException. Derivers must handle any reported exceptions in other ways.

Parameters:

command - the command that caused the exception

t - the exception

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor