org.apache.solr.util

Class OrderedExecutor

java.lang.Object

org.apache.solr.util.OrderedExecutor

All Implemented Interfaces:

Executor

public class OrderedExecutor
extends Object
implements Executor

Constructor Summary

Constructors

Constructor and Description
OrderedExecutor(int numThreads, ExecutorService delegate)

Method Summary

Modifier and Type	Method and Description
void	execute(Integer lockId, Runnable command) Execute the given command in the future.
void	execute(Runnable runnable)
void	shutdownAndAwaitTermination()

Methods inherited from class java.lang.Object

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

Constructor Detail

OrderedExecutor

public OrderedExecutor(int numThreads,
                       ExecutorService delegate)

Method Detail

execute

public void execute(Runnable runnable)

Specified by:

execute in interface Executor

execute

public void execute(Integer lockId,
                    Runnable command)

Execute the given command in the future. If another command with same lockId is waiting in the queue or running, this method will block until that command finish. Therefore different commands with same hash will be executed in order of calling this method. If multiple caller are waiting for a command to finish, there are no guarantee that the earliest call will win.

Parameters:

lockId - of the command, if null then a random hash will be generated

command - the runnable task

Throws:

RejectedExecutionException - if this task cannot be accepted for execution

shutdownAndAwaitTermination

public void shutdownAndAwaitTermination()