public class ExecuteProduceConsume extends ExecutingExecutionStrategy implements ExecutionStrategy, Runnable
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.
Modifier and Type | Class and Description |
---|---|
static class |
ExecuteProduceConsume.Factory |
ExecutionStrategy.DefaultExecutionStrategyFactory, ExecutionStrategy.Producer, ExecutionStrategy.Rejectable
Constructor and Description |
---|
ExecuteProduceConsume(ExecutionStrategy.Producer producer,
Executor executor) |
ExecuteProduceConsume(ExecutionStrategy.Producer producer,
Executor executor,
ExecutionStrategy lowResourceStrategy)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
dispatch()
Initiates (or resumes) the task production and execution.
|
void |
execute()
Initiates (or resumes) the task production and execution.
|
protected void |
executeProduct(Runnable task)
Only called when in
low threads mode
to execute the task produced by the producer. |
Boolean |
isIdle() |
boolean |
isLowOnThreads() |
void |
run() |
String |
toString() |
execute
public ExecuteProduceConsume(ExecutionStrategy.Producer producer, Executor executor)
@Deprecated public ExecuteProduceConsume(ExecutionStrategy.Producer producer, Executor executor, ExecutionStrategy lowResourceStrategy)
public void execute()
ExecutionStrategy
Initiates (or resumes) the task production and execution.
The produced task may be run by the same thread that called this method.
execute
in interface ExecutionStrategy
ExecutionStrategy.dispatch()
public void dispatch()
ExecutionStrategy
Initiates (or resumes) the task production and execution.
This method guarantees that the task is never run by the thread that called this method.
dispatch
in interface ExecutionStrategy
ExecutionStrategy.execute()
public boolean isLowOnThreads()
protected void executeProduct(Runnable task)
Only called when in low threads mode
to execute the task produced by the producer.
Because
If the task implements Rejectable
, then Rejectable#reject()
is immediately called on the task object. If the task also implements
Closeable
, then Closeable.close()
is called on the task object.
If the task does not implement Rejectable
, then it is
executed
.
task
- the produced task to executepublic Boolean isIdle()
Copyright © 1995-2016 Webtide. All Rights Reserved.