Package com.intellij.util

Class ConcurrencyUtil

java.lang.Object

com.intellij.util.ConcurrencyUtil

public final class ConcurrencyUtil
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ConcurrencyUtil()

Method Summary

Modifier and Type	Method and Description
static void	awaitQuiescence(java.util.concurrent.ThreadPoolExecutor executor, long timeout, java.util.concurrent.TimeUnit unit) Awaits for all tasks in the executor to finish for the specified timeout
static <T> T	cacheOrGet(java.util.concurrent.atomic.AtomicReference<T> ref, T defaultValue)
static <K,V> V	cacheOrGet(java.util.concurrent.ConcurrentMap<K,V> map, K key, V defaultValue)
static void	getAll(java.util.Collection<? extends java.util.concurrent.Future<?>> futures)
static <T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, java.util.concurrent.ExecutorService executorService) Invokes and waits all tasks using threadPool, avoiding thread starvation on the way (see "A Thread Pool Puzzler").
static void	joinAll(java.util.Collection<? extends java.lang.Thread> threads)
static void	joinAll(java.lang.Thread... threads)
static java.util.concurrent.ThreadFactory	newNamedThreadFactory(java.lang.String name)
static java.util.concurrent.ThreadFactory	newNamedThreadFactory(java.lang.String name, boolean isDaemon, int priority)
static java.util.concurrent.ExecutorService	newSameThreadExecutorService() Service which executes tasks synchronously immediately after they submitted
static java.util.concurrent.ScheduledThreadPoolExecutor	newSingleScheduledThreadExecutor(java.lang.String name)
static java.util.concurrent.ScheduledThreadPoolExecutor	newSingleScheduledThreadExecutor(java.lang.String name, int priority)
static java.util.concurrent.ThreadPoolExecutor	newSingleThreadExecutor(java.lang.String name)
static java.util.concurrent.ThreadPoolExecutor	newSingleThreadExecutor(java.lang.String name, int priority)
static java.lang.Runnable	once(java.lang.Runnable delegate)
static void	runUnderThreadName(java.lang.String name, java.lang.Runnable runnable)
static java.lang.Runnable	underThreadNameRunnable(java.lang.String name, java.lang.Runnable runnable)
static <T,E extends java.lang.Throwable> T	withLock(java.util.concurrent.locks.Lock lock, ThrowableComputable<T,E> runnable)
static <E extends java.lang.Throwable> void	withLock(java.util.concurrent.locks.Lock lock, ThrowableRunnable<E> runnable)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrencyUtil

public ConcurrencyUtil()

Method Detail

invokeAll

public static <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks,
                                                                           java.util.concurrent.ExecutorService executorService)
                                                                    throws java.lang.Throwable

Invokes and waits all tasks using threadPool, avoiding thread starvation on the way (see "A Thread Pool Puzzler").

Throws:

java.lang.Throwable

cacheOrGet

public static <K,V> V cacheOrGet(java.util.concurrent.ConcurrentMap<K,V> map,
                                 K key,
                                 V defaultValue)

Returns:

defaultValue if there is no entry in the map (in that case defaultValue is placed into the map), or corresponding value if entry already exists.

cacheOrGet

public static <T> T cacheOrGet(java.util.concurrent.atomic.AtomicReference<T> ref,
                               T defaultValue)

Returns:

defaultValue if the reference contains null (in that case defaultValue is placed there), or reference value otherwise.

newSingleThreadExecutor

public static java.util.concurrent.ThreadPoolExecutor newSingleThreadExecutor(java.lang.String name)

newSingleThreadExecutor

public static java.util.concurrent.ThreadPoolExecutor newSingleThreadExecutor(java.lang.String name,
                                                                              int priority)

newSingleScheduledThreadExecutor

public static java.util.concurrent.ScheduledThreadPoolExecutor newSingleScheduledThreadExecutor(java.lang.String name)

newSingleScheduledThreadExecutor

public static java.util.concurrent.ScheduledThreadPoolExecutor newSingleScheduledThreadExecutor(java.lang.String name,
                                                                                                int priority)

newSameThreadExecutorService

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

Service which executes tasks synchronously immediately after they submitted

newNamedThreadFactory

public static java.util.concurrent.ThreadFactory newNamedThreadFactory(java.lang.String name,
                                                                       boolean isDaemon,
                                                                       int priority)

newNamedThreadFactory

public static java.util.concurrent.ThreadFactory newNamedThreadFactory(java.lang.String name)

awaitQuiescence

public static void awaitQuiescence(java.util.concurrent.ThreadPoolExecutor executor,
                                   long timeout,
                                   java.util.concurrent.TimeUnit unit)

Awaits for all tasks in the executor to finish for the specified timeout

joinAll

public static void joinAll(java.util.Collection<? extends java.lang.Thread> threads)
                    throws java.lang.RuntimeException

Throws:

java.lang.RuntimeException

joinAll

public static void joinAll(java.lang.Thread... threads)
                    throws java.lang.RuntimeException

Throws:

java.lang.RuntimeException

getAll

public static void getAll(java.util.Collection<? extends java.util.concurrent.Future<?>> futures)
                   throws java.util.concurrent.ExecutionException,
                          java.lang.InterruptedException

Throws:

java.util.concurrent.ExecutionException

java.lang.InterruptedException

underThreadNameRunnable

public static java.lang.Runnable underThreadNameRunnable(java.lang.String name,
                                                         java.lang.Runnable runnable)

runUnderThreadName

public static void runUnderThreadName(java.lang.String name,
                                      java.lang.Runnable runnable)

once

public static java.lang.Runnable once(java.lang.Runnable delegate)

withLock

public static <T,E extends java.lang.Throwable> T withLock(java.util.concurrent.locks.Lock lock,
                                                           ThrowableComputable<T,E> runnable)
                                                    throws E extends java.lang.Throwable

Throws:

E extends java.lang.Throwable

withLock

public static <E extends java.lang.Throwable> void withLock(java.util.concurrent.locks.Lock lock,
                                                            ThrowableRunnable<E> runnable)
                                                     throws E extends java.lang.Throwable

Throws:

E extends java.lang.Throwable