Package org.axonframework.axonserver.connector.util

Class PriorityExecutorService

java.lang.Object

org.axonframework.axonserver.connector.util.PriorityExecutorService

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService

public class PriorityExecutorService
extends Object
implements ExecutorService

This ExecutorService wraps an existing one, creating a PriorityTask for every Runnable that is submitted that's an instance of one. The created PriorityTask will have the priority provided in the constructor, as well as the taskSequence provided there.

This implementation also diverts all invocations of ExecutorService.submit(Runnable) to Executor.execute(Runnable) instead. This is because the submit method implementations wrap the tasks in another FutureTask, which makes the task uncomparable again.

Since:

4.6.0

Author:

Mitchell Herrijgers, Milan Savic

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
void	execute(Runnable command)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
boolean	isShutdown()
boolean	isTerminated()
void	shutdown()
List<Runnable>	shutdownNow()
Future<?>	submit(Runnable task)
<T> Future<T>	submit(Runnable task, T result)
<T> Future<T>	submit(Callable<T> task)

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

close

Method Details

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

@Nonnull
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,
 @Nonnull
 TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

submit

@Nonnull
public <T> Future<T> submit(@Nonnull
 Callable<T> task)

Specified by:

submit in interface ExecutorService

submit

@Nonnull
public <T> Future<T> submit(@Nonnull
 Runnable task,
 T result)

Specified by:

submit in interface ExecutorService

submit

@Nonnull
public Future<?> submit(@Nonnull
 Runnable task)

Specified by:

submit in interface ExecutorService

invokeAll

@Nonnull
public <T> List<Future<T>> invokeAll(@Nonnull
 Collection<? extends Callable<T>> tasks)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

@Nonnull
public <T> List<Future<T>> invokeAll(@Nonnull
 Collection<? extends Callable<T>> tasks,
 long timeout,
 @Nonnull
 TimeUnit unit)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

@Nonnull
public <T> T invokeAny(@Nonnull
 Collection<? extends Callable<T>> tasks)
                throws InterruptedException,
ExecutionException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(@Nonnull
 Collection<? extends Callable<T>> tasks,
 long timeout,
 @Nonnull
 TimeUnit unit)
                throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

execute

public void execute(@Nonnull
 Runnable command)

Specified by:

execute in interface Executor