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

Class ToposortBasedDepsAwareExecutor<T>

java.lang.Object

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

All Implemented Interfaces:

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

public class ToposortBasedDepsAwareExecutor<T>
extends Object

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

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.ToposortBasedDepsAwareTask<T>	createTask(Callable<T> callable)
com.facebook.buck.core.graph.transformation.executor.impl.ToposortBasedDepsAwareTask<T>	createThrowingTask(Callable<T> callable, ThrowingSupplier<com.google.common.collect.ImmutableSet<com.facebook.buck.core.graph.transformation.executor.impl.ToposortBasedDepsAwareTask<T>>,Exception> prereqSupplier, ThrowingSupplier<com.google.common.collect.ImmutableSet<com.facebook.buck.core.graph.transformation.executor.impl.ToposortBasedDepsAwareTask<T>>,Exception> depsSupplier)
boolean	isShutdown()
static <U> ToposortBasedDepsAwareExecutor<U>	of(int numOfThreads) Creates a ToposortBasedDepsAwareExecutor with the given numOfThreads
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> ToposortBasedDepsAwareExecutor<U> of(int numOfThreads)

Creates a ToposortBasedDepsAwareExecutor with the given numOfThreads

createThrowingTask

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

Returns:

a new DepsAwareTask with two stages of dependency computation

createTask

public com.facebook.buck.core.graph.transformation.executor.impl.ToposortBasedDepsAwareTask<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)