com.facebook.buck.core.graph.transformation.executor.impl

Class DefaultDepsAwareExecutorWithLocalStack<T>

java.lang.Object

com.facebook.buck.core.graph.transformation.executor.impl.DefaultDepsAwareExecutorWithLocalStack<T>

All Implemented Interfaces:

DepsAwareExecutor<T,com.facebook.buck.core.graph.transformation.executor.impl.DefaultDepsAwareTask<T>>, AutoCloseable

public class DefaultDepsAwareExecutorWithLocalStack<T>
extends Object

A specialized Executor that executes DepsAwareTask. This executor will attempt to maintain maximum concurrency, while completing dependencies of each supplied work first.

This implementation uses workers that keep a local stack of tasks to avoid contention in the global queue.

Field Summary

Fields

Modifier and Type	Field and Description
protected Future<?>[]	workers
protected BlockingDeque<TaskType>	workQueue

Method Summary

Modifier and Type	Method and Description
void	close() Shuts down the executor workers immediately.
com.facebook.buck.core.graph.transformation.executor.impl.DefaultDepsAwareTask<T>	createTask(Callable<T> callable)
com.facebook.buck.core.graph.transformation.executor.impl.DefaultDepsAwareTask<T>	createThrowingTask(Callable<T> callable, ThrowingSupplier<com.google.common.collect.ImmutableSet<com.facebook.buck.core.graph.transformation.executor.impl.DefaultDepsAwareTask<T>>,Exception> prereqSupplier, ThrowingSupplier<com.google.common.collect.ImmutableSet<com.facebook.buck.core.graph.transformation.executor.impl.DefaultDepsAwareTask<T>>,Exception> depsSupplier)
boolean	isShutdown()
static <U> DefaultDepsAwareExecutorWithLocalStack<U>	of(int numberOfThreads) Creates a DefaultDepsAwareExecutor with given numberOfThreads.
protected static void	runWorker(com.facebook.buck.core.graph.transformation.executor.impl.AbstractDepsAwareWorker<?> worker)
protected static <TaskType extends com.facebook.buck.core.graph.transformation.executor.impl.AbstractDepsAwareTask<?,TaskType>,V extends com.facebook.buck.core.graph.transformation.executor.impl.AbstractDepsAwareWorker<TaskType>> Future<?>[]	startWorkers(ExecutorService executorService, int parallelism, LinkedBlockingDeque<TaskType> workQueue, java.util.function.Function<LinkedBlockingDeque<TaskType>,V> workerFunction)
Future<T>	submit(TaskType task)
com.google.common.collect.ImmutableList<Future<T>>	submitAll(Collection<TaskType> tasks) Same as DepsAwareExecutor.submit(DepsAwareTask) except for multiple tasks.

Methods inherited from class java.lang.Object

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

Field Detail

workQueue

protected final BlockingDeque<TaskType extends com.facebook.buck.core.graph.transformation.executor.impl.AbstractDepsAwareTask<T,TaskType>> workQueue

workers

protected final Future<?>[] workers

Method Detail

of

public static <U> DefaultDepsAwareExecutorWithLocalStack<U> of(int numberOfThreads)

Creates a DefaultDepsAwareExecutor with given numberOfThreads.

createThrowingTask

public com.facebook.buck.core.graph.transformation.executor.impl.DefaultDepsAwareTask<T> createThrowingTask(Callable<T> callable,
                                                                                                            ThrowingSupplier<com.google.common.collect.ImmutableSet<com.facebook.buck.core.graph.transformation.executor.impl.DefaultDepsAwareTask<T>>,Exception> prereqSupplier,
                                                                                                            ThrowingSupplier<com.google.common.collect.ImmutableSet<com.facebook.buck.core.graph.transformation.executor.impl.DefaultDepsAwareTask<T>>,Exception> depsSupplier)

Returns:

a new DepsAwareTask with two stages of dependency computation

createTask

public com.facebook.buck.core.graph.transformation.executor.impl.DefaultDepsAwareTask<T> createTask(Callable<T> callable)

Returns:

a new DepsAwareTask that can be executed in this executor

runWorker

protected static void runWorker(com.facebook.buck.core.graph.transformation.executor.impl.AbstractDepsAwareWorker<?> worker)

close

public void close()

Description copied from interface: DepsAwareExecutor

Shuts down the executor workers immediately. This does not shutdown the underlying executor backing the DepsAwareExecutor

Specified by:

close in interface DepsAwareExecutor<T,TaskType extends com.facebook.buck.core.graph.transformation.executor.impl.AbstractDepsAwareTask<T,TaskType>>

Specified by:

close in interface AutoCloseable

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface DepsAwareExecutor<T,TaskType extends com.facebook.buck.core.graph.transformation.executor.impl.AbstractDepsAwareTask<T,TaskType>>

Returns:

true iff DepsAwareExecutor.close() has been called

submit

public Future<T> submit(TaskType task)

Specified by:

submit in interface DepsAwareExecutor<T,TaskType extends com.facebook.buck.core.graph.transformation.executor.impl.AbstractDepsAwareTask<T,TaskType>>

Parameters:

task - the DepsAwareTask to run

Returns:

a future of the result

submitAll

public com.google.common.collect.ImmutableList<Future<T>> submitAll(Collection<TaskType> tasks)

Description copied from interface: DepsAwareExecutor

Same as DepsAwareExecutor.submit(DepsAwareTask) except for multiple tasks.

Specified by:

submitAll in interface DepsAwareExecutor<T,TaskType extends com.facebook.buck.core.graph.transformation.executor.impl.AbstractDepsAwareTask<T,TaskType>>

startWorkers

protected static <TaskType extends com.facebook.buck.core.graph.transformation.executor.impl.AbstractDepsAwareTask<?,TaskType>,V extends com.facebook.buck.core.graph.transformation.executor.impl.AbstractDepsAwareWorker<TaskType>> Future<?>[] startWorkers(ExecutorService executorService,
                                                                                                                                                                                                                                                               int parallelism,
                                                                                                                                                                                                                                                               LinkedBlockingDeque<TaskType> workQueue,
                                                                                                                                                                                                                                                               java.util.function.Function<LinkedBlockingDeque<TaskType>,V> workerFunction)