Package com.intellij.concurrency

Class JobLauncherImpl

java.lang.Object

com.intellij.concurrency.JobLauncher

com.intellij.concurrency.JobLauncherImpl

public class JobLauncherImpl
extends JobLauncher

Constructor Summary

Constructors

Constructor and Description
JobLauncherImpl()

Method Summary

Modifier and Type	Method and Description
<T> boolean	invokeConcurrentlyUnderProgress(java.util.List<? extends T> things, ProgressIndicator progress, boolean runInReadAction, boolean failFastOnAcquireReadAction, Processor<? super T> thingProcessor)
<T> boolean	processQueue(java.util.concurrent.BlockingQueue<T> things, java.util.Queue<T> failedToProcess, ProgressIndicator progress, T tombStone, Processor<? super T> thingProcessor) Process all elements from the failedToProcess and then things concurrently in the underlying pool.
Job<java.lang.Void>	submitToJobThread(java.lang.Runnable action, Consumer<? super java.util.concurrent.Future<?>> onDoneCallback) NEVER EVER submit runnable which can lock itself for indeterminate amount of time.

Methods inherited from class com.intellij.concurrency.JobLauncher

getInstance, invokeConcurrentlyUnderProgress, invokeConcurrentlyUnderProgress

Methods inherited from class java.lang.Object

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

Constructor Detail

JobLauncherImpl

public JobLauncherImpl()

Method Detail

invokeConcurrentlyUnderProgress

public <T> boolean invokeConcurrentlyUnderProgress(java.util.List<? extends T> things,
                                                   ProgressIndicator progress,
                                                   boolean runInReadAction,
                                                   boolean failFastOnAcquireReadAction,
                                                   Processor<? super T> thingProcessor)
                                            throws ProcessCanceledException

Specified by:

invokeConcurrentlyUnderProgress in class JobLauncher

Throws:

ProcessCanceledException

submitToJobThread

public Job<java.lang.Void> submitToJobThread(java.lang.Runnable action,
                                             Consumer<? super java.util.concurrent.Future<?>> onDoneCallback)

Description copied from class: JobLauncher

NEVER EVER submit runnable which can lock itself for indeterminate amount of time. This will cause deadlock since this thread pool is an easily exhaustible resource. Use Application.executeOnPooledThread(Runnable) instead

Specified by:

submitToJobThread in class JobLauncher

processQueue

public <T> boolean processQueue(java.util.concurrent.BlockingQueue<T> things,
                                java.util.Queue<T> failedToProcess,
                                ProgressIndicator progress,
                                T tombStone,
                                Processor<? super T> thingProcessor)

Process all elements from the failedToProcess and then things concurrently in the underlying pool. Processing happens concurrently maintaining JobSchedulerImpl.CORES_COUNT parallelism. Stop when tombStone element is occurred. If was unable to process some element, add it back to the failedToProcess queue.

Returns:

true if all elements processed successfully, false if at least one processor returned false or exception occurred