Package com.jozufozu.flywheel.backend.instancing

Class ParallelTaskEngine

java.lang.Object

com.jozufozu.flywheel.backend.instancing.ParallelTaskEngine

All Implemented Interfaces:

TaskEngine

public class ParallelTaskEngine
extends Object
implements TaskEngine

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ParallelTaskEngine.WorkGroupBuilder

Constructor Summary

Constructors

Constructor	Description
ParallelTaskEngine(String name)

Method Summary

Modifier and Type	Method	Description
ParallelTaskEngine.WorkGroupBuilder	group(String name)
void	startWorkers()	Spawns a number of work-stealing threads to process results in the build queue.
void	stopWorkers()
void	submit(@NotNull Runnable command)	Submit a task to the pool.
void	syncPoint()	Wait for all running jobs to finish.

Methods inherited from class java.lang.Object

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

Constructor Details

ParallelTaskEngine

public ParallelTaskEngine(String name)

Method Details

group

public ParallelTaskEngine.WorkGroupBuilder group(String name)

startWorkers

public void startWorkers()

Spawns a number of work-stealing threads to process results in the build queue. If the builder is already running, this method does nothing and exits.

stopWorkers

public void stopWorkers()

submit

public void submit(@NotNull
 @NotNull Runnable command)

Submit a task to the pool.

Specified by:

submit in interface TaskEngine

syncPoint

public void syncPoint()

Wait for all running jobs to finish.

Specified by:

syncPoint in interface TaskEngine