Package jetbrains.buildServer.serverSide.impl.executors

Class DeferringExecutorService

java.lang.Object

jetbrains.buildServer.serverSide.impl.executors.DeferringExecutorService

All Implemented Interfaces:

Executor, ExecutorService

Direct Known Subclasses:

DeferringScheduledExecutorService

public class DeferringExecutorService
extends Object
implements ExecutorService

Constructor Summary

Constructors

Constructor	Description
DeferringExecutorService(ScalingThreadPoolExecutor delegate)

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
void	enableExecution()
void	execute(Runnable command)
ScalingThreadPoolExecutor	getUnderlyingExecutorService()
<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()
void	shutdownInt()
List<Runnable>	shutdownNow()
void	shutdownNowInt()
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

Constructor Detail

DeferringExecutorService

public DeferringExecutorService(@NotNull
                                ScalingThreadPoolExecutor delegate)

Method Detail

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

@NotNull
public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

shutdownInt

public void shutdownInt()

shutdownNowInt

public void shutdownNowInt()

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

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

execute

public void execute(@NotNull
                    Runnable command)

Specified by:

execute in interface Executor

submit

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

Specified by:

submit in interface ExecutorService

submit

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

Specified by:

submit in interface ExecutorService

submit

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

Specified by:

submit in interface ExecutorService

invokeAll

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

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

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

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

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

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

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

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

enableExecution

public void enableExecution()

getUnderlyingExecutorService

@NotNull
public ScalingThreadPoolExecutor getUnderlyingExecutorService()