Package com.intellij.util.concurrency

Class AppScheduledExecutorService

java.lang.Object

com.intellij.util.concurrency.AppScheduledExecutorService

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService, ScheduledExecutorService

public class AppScheduledExecutorService
extends Object

A ThreadPoolExecutor which also implements ScheduledExecutorService by awaiting scheduled tasks in a separate thread and then executing them in the owned ThreadPoolExecutor. Unlike the existing ScheduledThreadPoolExecutor, this pool is unbounded.

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit unit)
void	execute(Runnable command)
int	getBackendPoolExecutorSize()
<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()
ScheduledFuture<?>	schedule(Runnable command, long delay, TimeUnit unit)
<V> ScheduledFuture<V>	schedule(Callable<V> callable, long delay, TimeUnit unit)
ScheduledFuture<?>	scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
ScheduledFuture<?>	scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)
void	setNewThreadListener(Consumer<Thread> threadListener)
void	shutdown()
void	shutdownAppScheduledExecutorService()
List<Runnable>	shutdownNow()
String	statistics()
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

setNewThreadListener

public void setNewThreadListener(@NotNull
 Consumer<Thread> threadListener)

shutdownNow

@NotNull
public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownAppScheduledExecutorService

public void shutdownAppScheduledExecutorService()

statistics

@NotNull
@TestOnly
public String statistics()

getBackendPoolExecutorSize

public int getBackendPoolExecutorSize()

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

schedule

@NotNull
public ScheduledFuture<?> schedule(@NotNull
 Runnable command,
 long delay,
 @NotNull
 TimeUnit unit)

Specified by:

schedule in interface ScheduledExecutorService

schedule

@NotNull
public <V> ScheduledFuture<V> schedule(@NotNull
 Callable<V> callable,
 long delay,
 @NotNull
 TimeUnit unit)

Specified by:

schedule in interface ScheduledExecutorService

scheduleAtFixedRate

@NotNull
public ScheduledFuture<?> scheduleAtFixedRate(@NotNull
 Runnable command,
 long initialDelay,
 long period,
 @NotNull
 TimeUnit unit)

Specified by:

scheduleAtFixedRate in interface ScheduledExecutorService

scheduleWithFixedDelay

@NotNull
public ScheduledFuture<?> scheduleWithFixedDelay(@NotNull
 Runnable command,
 long initialDelay,
 long delay,
 @NotNull
 TimeUnit unit)

Specified by:

scheduleWithFixedDelay in interface ScheduledExecutorService

submit

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

Specified by:

submit in interface ExecutorService

submit

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

Specified by:

submit in interface ExecutorService

submit

@NotNull
public Future<?> submit(@NotNull
 Runnable 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

execute

public void execute(@NotNull
 Runnable command)

Specified by:

execute in interface Executor