org.gradle.api.internal.tasks.testing.processors

Class MaxNParallelTestClassProcessor

java.lang.Object

org.gradle.api.internal.tasks.testing.processors.MaxNParallelTestClassProcessor

All Implemented Interfaces:

TestClassProcessor, Stoppable

public class MaxNParallelTestClassProcessor
extends Object
implements TestClassProcessor

Manages a set of parallel TestClassProcessors. Uses a simple round-robin algorithm to assign test classes to processors.

Constructor Summary

Constructors

Constructor and Description
MaxNParallelTestClassProcessor(int maxProcessors, Factory<TestClassProcessor> factory, ActorFactory actorFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	processTestClass(TestClassRunInfo testClass) Accepts the given test class for processing.
void	startProcessing(TestResultProcessor resultProcessor) Performs any initialisation which this processor needs to perform.
void	stop() Completes any pending or asynchronous processing.

Methods inherited from class java.lang.Object

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

Constructor Detail

MaxNParallelTestClassProcessor

public MaxNParallelTestClassProcessor(int maxProcessors,
                              Factory<TestClassProcessor> factory,
                              ActorFactory actorFactory)

Method Detail

startProcessing

public void startProcessing(TestResultProcessor resultProcessor)

Description copied from interface: TestClassProcessor

Performs any initialisation which this processor needs to perform.

Specified by:

startProcessing in interface TestClassProcessor

Parameters:

resultProcessor - The processor to send results to during test execution.

processTestClass

public void processTestClass(TestClassRunInfo testClass)

Description copied from interface: TestClassProcessor

Accepts the given test class for processing. May execute synchronously, asynchronously, or defer execution for later.

Specified by:

processTestClass in interface TestClassProcessor

Parameters:

testClass - The test class.

stop

public void stop()

Description copied from interface: TestClassProcessor

Completes any pending or asynchronous processing. Blocks until all processing is complete. The processor should not use the result processor provided to TestClassProcessor.startProcessing(TestResultProcessor) after this method has returned.

Specified by:

stop in interface TestClassProcessor

Specified by:

stop in interface Stoppable