A strategy where the thread that produces will always run the resulting task.

The strategy may then dispatch another thread to continue production.

The strategy is also known by the nickname 'eat what you kill', which comes from the hunting ethic that says a person should not kill anything he or she does not plan on eating. In this case, the phrase is used to mean that a thread should not produce a task that it does not intend to run. By making producers run the task that they have just produced avoids execution delays and avoids parallel slow down by running the task in the same core, with good chances of having a hot CPU cache. It also avoids the creation of a queue of produced tasks that the system does not yet have capacity to consume, which can save memory and exert back pressure on producers.

Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	ExecuteProduceConsume.RunProduce

Field Summary

Modifier and Type	Field and Description
private boolean	_execute
private final Executor	_executor
private boolean	_idle
private final AutoLock	_lock
private boolean	_pending
private final ExecutionStrategy.Producer	_producer
private boolean	_producing
private final Runnable	_runProduce
private static final Logger	LOG

Constructor Summary

Access	Constructor and Description
public	ExecuteProduceConsume(ExecutionStrategy.Producer producer, Executor executor)

Method Summary

Modifier and Type	Method and Description
public void	dispatch() Implements org.eclipse.jetty.util.thread.ExecutionStrategy.dispatch. Initiates (or resumes) the task production and consumption.
public Boolean	isIdle()
public void	produce() Implements org.eclipse.jetty.util.thread.ExecutionStrategy.produce. Initiates (or resumes) the task production and consumption.
private void	produceConsume()
public void	run() Implements java.lang.Runnable.run. Runs this operation.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

_execute	back to summary
private boolean _execute

_executor	back to summary
private final Executor _executor

_idle	back to summary
private boolean _idle

_lock	back to summary
private final AutoLock _lock

_pending	back to summary
private boolean _pending

_producer	back to summary
private final ExecutionStrategy.Producer _producer

_producing	back to summary
private boolean _producing

_runProduce	back to summary
private final Runnable _runProduce

LOG	back to summary
private static final Logger LOG

Constructor Detail

ExecuteProduceConsume	back to summary
public ExecuteProduceConsume(ExecutionStrategy.Producer producer, Executor executor)

Method Detail

dispatch	back to summary
public void dispatch() Implements org.eclipse.jetty.util.thread.ExecutionStrategy.dispatch. Doc from org.eclipse.jetty.util.thread.ExecutionStrategy.dispatch. Initiates (or resumes) the task production and consumption. This method guarantees that the task is never run by the thread that called this method. TODO review the need for this (only used by HTTP2 push) Annotations @Override

dispatch

back to summary

public void dispatch()

Implements org.eclipse.jetty.util.thread.ExecutionStrategy.dispatch.

Doc from org.eclipse.jetty.util.thread.ExecutionStrategy.dispatch.

Initiates (or resumes) the task production and consumption.

This method guarantees that the task is never run by the thread that called this method.

TODO review the need for this (only used by HTTP2 push)

Annotations

@Override

isIdle	back to summary
public Boolean isIdle()

produce	back to summary
public void produce() Implements org.eclipse.jetty.util.thread.ExecutionStrategy.produce. Doc from org.eclipse.jetty.util.thread.ExecutionStrategy.produce. Initiates (or resumes) the task production and consumption. The produced task may be run by the same thread that called this method. Annotations @Override

produce

back to summary

public void produce()

Implements org.eclipse.jetty.util.thread.ExecutionStrategy.produce.

Doc from org.eclipse.jetty.util.thread.ExecutionStrategy.produce.

Initiates (or resumes) the task production and consumption.

The produced task may be run by the same thread that called this method.

Annotations

@Override

produceConsume	back to summary
private void produceConsume()

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

toString back to summary

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Returns:String a string representation of the object Annotations @Override

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations