Package net.officefloor.web.executive

Class WebThreadAffinityExecutive

java.lang.Object

net.officefloor.web.executive.WebThreadAffinityExecutive

All Implemented Interfaces:

ExecutionStrategy, Executive, TeamOversight

public class WebThreadAffinityExecutive
extends java.lang.Object
implements Executive, ExecutionStrategy, TeamOversight

Web Thread affinity Executive.

Author:

Daniel Sagenschneider

Constructor Summary

Constructors

Constructor	Description
WebThreadAffinityExecutive(CpuCore[] cpuCores, ExecutiveSourceContext context)	Instantiate.

Method Summary

Modifier and Type	Method	Description
java.lang.Object	createProcessIdentifier()	Creates a new ProcessState identifier.
Team	createTeam(ExecutiveContext context)	Creates the Team.
ExecutionStrategy[]	getExcutionStrategies()	Obtains the ExecutionStrategy strategies.
java.lang.String	getExecutionStrategyName()	Obtains the name of the ExecutionStrategy.
java.lang.String	getTeamOversightName()	Obtains the name of the TeamOversight.
TeamOversight[]	getTeamOversights()	Obtains the TeamOversight instances.
java.util.concurrent.ThreadFactory[]	getThreadFactories()	Obtains the ThreadFactory instances for the various Thread instances of this ExecutionStrategy.
<T extends java.lang.Throwable> ProcessManager	manageExecution(Execution<T> execution)	Manages the Execution.

Methods inherited from class java.lang.Object

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

Constructor Detail

WebThreadAffinityExecutive

public WebThreadAffinityExecutive(CpuCore[] cpuCores,
                                  ExecutiveSourceContext context)

Instantiate.

Parameters:

cpuCores - CpuCore instances.

context - ExecutiveSourceContext.

Method Detail

createProcessIdentifier

public java.lang.Object createProcessIdentifier()

Description copied from interface: Executive

Creates a new ProcessState identifier.

Specified by:

createProcessIdentifier in interface Executive

Returns:

New ProcessState identifier.

manageExecution

public <T extends java.lang.Throwable> ProcessManager manageExecution(Execution<T> execution)
                                                               throws T extends java.lang.Throwable

Description copied from interface: Executive

Manages the Execution.

The Thread.currentThread() will provide the inbound Thread.

Specified by:

manageExecution in interface Executive

Type Parameters:

T - Type of Throwable thrown.

Parameters:

execution - Execution to be undertaken.

Returns:

ProcessManager for the ProcessState.

Throws:

T - Propagation of failure from Execution.

T extends java.lang.Throwable

getExcutionStrategies

public ExecutionStrategy[] getExcutionStrategies()

Description copied from interface: Executive

Obtains the ExecutionStrategy strategies.

Specified by:

getExcutionStrategies in interface Executive

Returns:

ExecutionStrategy instances.

getTeamOversights

public TeamOversight[] getTeamOversights()

Description copied from interface: Executive

Obtains the TeamOversight instances.

Specified by:

getTeamOversights in interface Executive

Returns:

TeamOversight instances.

getExecutionStrategyName

public java.lang.String getExecutionStrategyName()

Description copied from interface: ExecutionStrategy

Obtains the name of the ExecutionStrategy.

Specified by:

getExecutionStrategyName in interface ExecutionStrategy

Returns:

Name of the ExecutionStrategy.

getThreadFactories

public java.util.concurrent.ThreadFactory[] getThreadFactories()

Description copied from interface: ExecutionStrategy

Obtains the ThreadFactory instances for the various Thread instances of this ExecutionStrategy.

Specified by:

getThreadFactories in interface ExecutionStrategy

Returns:

ThreadFactory instances.

getTeamOversightName

public java.lang.String getTeamOversightName()

Description copied from interface: TeamOversight

Obtains the name of the TeamOversight.

Specified by:

getTeamOversightName in interface TeamOversight

Returns:

Name of the TeamOversight.

createTeam

public Team createTeam(ExecutiveContext context)
                throws java.lang.Exception

Description copied from interface: TeamOversight

Creates the Team.

This is expected to delegate to the TeamSource to create the Team. However, the Executive may decide to wrap the Team or provide multiple Team instances with assigning algorithm (such as taking advantage of Thread affinity). The choice is, however, ultimately left to the Executive to manage the Team instances.

Specified by:

createTeam in interface TeamOversight

Parameters:

context - ExecutiveContext.

Returns:

Team.

Throws:

java.lang.Exception - If fails to configure the TeamSource.