com.ebay.bascomtask.core

Class LaneRunner<T extends TaskRunner>

java.lang.Object

com.ebay.bascomtask.core.LaneRunner<T>

Type Parameters:

T - type of TaskRunner to create

All Implemented Interfaces:

AutoCloseable

public class LaneRunner<T extends TaskRunner>
extends Object
implements AutoCloseable

Establishes a TaskRunner creation capability that for each new Orchestrator created in this thread will be applied and recorded for later retrieval.

Author:

bremccarthy

See Also:

GlobalOrchestratorConfig.interceptFirstOnCreate(Supplier)

Field Summary

Fields

Modifier and Type	Field and Description
List<T>	runners Exposes all TaskRunners created by the thread that invoked the constructor, up until the time this LaneRunner was closed (if it has been closed).

Method Summary

Modifier and Type	Method and Description
void	close()

Methods inherited from class java.lang.Object

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

Field Detail

runners

public final List<T extends TaskRunner> runners

Exposes all TaskRunners created by the thread that invoked the constructor, up until the time this LaneRunner was closed (if it has been closed). This will usually be just zero or one, but implementations are free to create as many orchestrators as desired. Beware that orchestrators created in spawned threads will not be visible to this instance.

Care should be taken if this list is retrieved asynchronously since the list might still be added to. A safe strategy is to retrieve the list at a point when all processing for this thread is completed. Otherwise, the standard Java practices around avoiding ConcurrentModificationExceptions when traversing lists should be practiced.

Method Detail

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception