com.ebay.bascomtask.core

Class ThreadLocalRunners<RUNNER extends TaskRunner>

java.lang.Object

com.ebay.bascomtask.core.ThreadLocalRunners<RUNNER>

public class ThreadLocalRunners<RUNNER extends TaskRunner>
extends Object

Allows setting of a per-orchestrator TaskRunner that applies to an Orchestrator created by the current thread using ThreadLocal storage.

Author:

Brendan McCarthy

Constructor Summary

Constructors

Constructor and Description
ThreadLocalRunners()

Method Summary

Modifier and Type	Method and Description
void	firstInterceptWith(Supplier<RUNNER> fn) Adds a TaskRunner to each new Orchestrator at the head of the list.
void	firstInterceptWith(Supplier<RUNNER> fn, BiPredicate<Orchestrator,Object> pred) Adds a TaskRunner to each new Orchestrator at the head of the list if the supplied predicate is true.
RUNNER	getAndClear() Returns the TaskRunner last generated by the supplier function to firstInterceptWith(Supplier) or firstInterceptWith(Supplier, BiPredicate) for this thread.
void	lastInterceptWith(Supplier<RUNNER> fn) Adds a TaskRunner to each new Orchestrator to the tail of the list.
void	lastInterceptWith(Supplier<RUNNER> fn, BiPredicate<Orchestrator,Object> pred) Adds a TaskRunner to each new Orchestrator to the tail of the list if the supplied predicate is true.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadLocalRunners

public ThreadLocalRunners()

Method Detail

firstInterceptWith

public void firstInterceptWith(Supplier<RUNNER> fn)

Adds a TaskRunner to each new Orchestrator at the head of the list.

Parameters:

fn - to generate the TaskRunner to add

lastInterceptWith

public void lastInterceptWith(Supplier<RUNNER> fn)

Adds a TaskRunner to each new Orchestrator to the tail of the list.

Parameters:

fn - to generate the TaskRunner to add

firstInterceptWith

public void firstInterceptWith(Supplier<RUNNER> fn,
                               BiPredicate<Orchestrator,Object> pred)

Adds a TaskRunner to each new Orchestrator at the head of the list if the supplied predicate is true. The predicate arguments are the same as those for GlobalOrchestratorConfig.Config.afterDefaultInitialization(Orchestrator, Object).

Parameters:

fn - to generate the TaskRunner to add

lastInterceptWith

public void lastInterceptWith(Supplier<RUNNER> fn,
                              BiPredicate<Orchestrator,Object> pred)

Adds a TaskRunner to each new Orchestrator to the tail of the list if the supplied predicate is true. The predicate arguments are the same as those for GlobalOrchestratorConfig.Config.afterDefaultInitialization(Orchestrator, Object).

Parameters:

fn - to generate the TaskRunner to add

getAndClear

public RUNNER getAndClear()

Returns the TaskRunner last generated by the supplier function to firstInterceptWith(Supplier) or firstInterceptWith(Supplier, BiPredicate) for this thread. If more than one Orchestrator was created for this thread since one of those methods was called, this will only return the last one.

Returns:

the last TaskRunner created for this thread