Package com.intellij.util.concurrency

Class AppExecutorUtil

java.lang.Object

com.intellij.util.concurrency.AppExecutorUtil

public final class AppExecutorUtil
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
AppExecutorUtil()

Method Summary

Modifier and Type	Method and Description
static java.util.concurrent.ExecutorService	createBoundedApplicationPoolExecutor(java.lang.String name, java.util.concurrent.Executor backendExecutor, int maxThreads)
static java.util.concurrent.ExecutorService	createBoundedApplicationPoolExecutor(java.lang.String name, java.util.concurrent.Executor backendExecutor, int maxThreads, Disposable parentDisposable)
static java.util.concurrent.ExecutorService	createBoundedApplicationPoolExecutor(java.lang.String name, int maxThreads)
static java.util.concurrent.ExecutorService	createBoundedApplicationPoolExecutor(java.lang.String name, int maxThreads, boolean changeThreadName)
static java.util.concurrent.ScheduledExecutorService	createBoundedScheduledExecutorService(java.lang.String name, int maxThreads) Returns ScheduledExecutorService which allows to ScheduledExecutorService.schedule(Callable, long, TimeUnit) tasks later and execute them in parallel in the application pool (see getAppExecutorService() not more than at maxThreads at a time.
static java.util.concurrent.ExecutorService	createCustomPriorityQueueBoundedApplicationPoolExecutor(java.lang.String name, java.util.concurrent.Executor backendExecutor, int maxThreads, java.util.Comparator<? super java.lang.Runnable> comparator)
static java.util.concurrent.ExecutorService	getAppExecutorService() Application thread pool.
static java.util.concurrent.ScheduledExecutorService	getAppScheduledExecutorService() Returns application-wide instance of ScheduledExecutorService which is: Unbounded.

Methods inherited from class java.lang.Object

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

Constructor Detail

AppExecutorUtil

public AppExecutorUtil()

Method Detail

getAppScheduledExecutorService

public static java.util.concurrent.ScheduledExecutorService getAppScheduledExecutorService()

Returns application-wide instance of ScheduledExecutorService which is:

• Unbounded. I.e. multiple ScheduledExecutorService.schedule(java.lang.Runnable, long, java.util.concurrent.TimeUnit)(command, 0, TimeUnit.SECONDS) will lead to multiple executions of the command in parallel.
• Backed by the application thread pool. I.e. every scheduled task will be executed in the IDE's own thread pool. See Application.executeOnPooledThread(Runnable)
• Non-shutdownable singleton. Any attempts to call ExecutorService.shutdown(), ExecutorService.shutdownNow() will be severely punished.
• ScheduledExecutorService.scheduleAtFixedRate(Runnable, long, long, TimeUnit) is disallowed because it's bad for hibernation. Use ScheduledExecutorService.scheduleWithFixedDelay(Runnable, long, long, TimeUnit) instead.

getAppExecutorService

public static java.util.concurrent.ExecutorService getAppExecutorService()

Application thread pool. This pool is

• Unbounded.
• Application-wide, always active, non-shutdownable singleton.

You can use this pool for long-running and/or IO-bound tasks.

See Also:

Application.executeOnPooledThread(Runnable)

createBoundedScheduledExecutorService

public static java.util.concurrent.ScheduledExecutorService createBoundedScheduledExecutorService(java.lang.String name,
                                                                                                  int maxThreads)

Returns ScheduledExecutorService which allows to ScheduledExecutorService.schedule(Callable, long, TimeUnit) tasks later and execute them in parallel in the application pool (see getAppExecutorService() not more than at maxThreads at a time.

createBoundedApplicationPoolExecutor

public static java.util.concurrent.ExecutorService createBoundedApplicationPoolExecutor(java.lang.String name,
                                                                                        int maxThreads)

Returns:

the bounded executor (executor which runs no more than maxThreads tasks simultaneously) backed by the application pool (i.e. all tasks are run in the getAppExecutorService() global thread pool).

See Also:

getAppExecutorService()

createBoundedApplicationPoolExecutor

public static java.util.concurrent.ExecutorService createBoundedApplicationPoolExecutor(java.lang.String name,
                                                                                        int maxThreads,
                                                                                        boolean changeThreadName)

createBoundedApplicationPoolExecutor

public static java.util.concurrent.ExecutorService createBoundedApplicationPoolExecutor(java.lang.String name,
                                                                                        java.util.concurrent.Executor backendExecutor,
                                                                                        int maxThreads)

Returns:

the bounded executor (executor which runs no more than maxThreads tasks simultaneously) backed by the backendExecutor

createBoundedApplicationPoolExecutor

public static java.util.concurrent.ExecutorService createBoundedApplicationPoolExecutor(java.lang.String name,
                                                                                        java.util.concurrent.Executor backendExecutor,
                                                                                        int maxThreads,
                                                                                        Disposable parentDisposable)

Returns:

the bounded executor (executor which runs no more than maxThreads tasks simultaneously) backed by the backendExecutor which will shutdown itself when parentDisposable gets disposed.

createCustomPriorityQueueBoundedApplicationPoolExecutor

public static java.util.concurrent.ExecutorService createCustomPriorityQueueBoundedApplicationPoolExecutor(java.lang.String name,
                                                                                                           java.util.concurrent.Executor backendExecutor,
                                                                                                           int maxThreads,
                                                                                                           java.util.Comparator<? super java.lang.Runnable> comparator)

Returns:

the bounded executor (executor which runs no more than maxThreads tasks simultaneously) backed by the backendExecutor which will shutdown itself when parentDisposable gets disposed.