org.easetech.easytest.strategy

Class ParallelScheduler

java.lang.Object

org.easetech.easytest.strategy.ParallelScheduler

All Implemented Interfaces:

org.junit.runners.model.RunnerScheduler

public class ParallelScheduler
extends Object
implements org.junit.runners.model.RunnerScheduler

RunnerScheduler implementation to run tests in Parallel.

Author:

Anuj Kumar

Constructor Summary

Constructors

Constructor and Description
ParallelScheduler() Construct a new ParallelScheduler.
ParallelScheduler(int threadsToStart) Construct a new ParallelScheduler This creates a fixed thread pool executor Service, where the user passes the number of threads he wants to start

Method Summary

Methods

Modifier and Type	Method and Description
void	finished() Method called when all the test methods have been executed by the ExecutorService instance.
ExecutorService	getExecutorService()
void	schedule(Runnable childStatement) Schedule a Runnable Statement

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelScheduler

public ParallelScheduler()

Construct a new ParallelScheduler. This creates a Cached Thread Pool Executor Service

ParallelScheduler

public ParallelScheduler(int threadsToStart)

Construct a new ParallelScheduler This creates a fixed thread pool executor Service, where the user passes the number of threads he wants to start

Parameters:

threadsToStart - the number of threads in the thread pool

Method Detail

schedule

public void schedule(Runnable childStatement)

Schedule a Runnable Statement

Specified by:

schedule in interface org.junit.runners.model.RunnerScheduler

Parameters:

childStatement - a runnable implementation

finished

public void finished()

Method called when all the test methods have been executed by the ExecutorService instance. This method is used to shutdown and await for termination of all threads.

Specified by:

finished in interface org.junit.runners.model.RunnerScheduler

getExecutorService

public ExecutorService getExecutorService()

Returns:

the executorService