Class ProduceExecuteConsume
- java.lang.Object
-
- org.eclipse.jetty.util.thread.strategy.ProduceExecuteConsume
-
- All Implemented Interfaces:
ExecutionStrategy
public class ProduceExecuteConsume extends java.lang.Object implements ExecutionStrategy
A strategy where the caller thread iterates over task production, submitting each task to an
Executor
for execution.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
ProduceExecuteConsume.State
-
Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.ExecutionStrategy
ExecutionStrategy.Producer
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.Executor
_executor
private Locker
_locker
private ExecutionStrategy.Producer
_producer
private ProduceExecuteConsume.State
_state
private static Logger
LOG
-
Constructor Summary
Constructors Constructor Description ProduceExecuteConsume(ExecutionStrategy.Producer producer, java.util.concurrent.Executor executor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
dispatch()
Initiates (or resumes) the task production and consumption.void
produce()
Initiates (or resumes) the task production and consumption.
-
-
-
Field Detail
-
LOG
private static final Logger LOG
-
_locker
private final Locker _locker
-
_producer
private final ExecutionStrategy.Producer _producer
-
_executor
private final java.util.concurrent.Executor _executor
-
_state
private ProduceExecuteConsume.State _state
-
-
Constructor Detail
-
ProduceExecuteConsume
public ProduceExecuteConsume(ExecutionStrategy.Producer producer, java.util.concurrent.Executor executor)
-
-
Method Detail
-
produce
public void produce()
Description copied from interface:ExecutionStrategy
Initiates (or resumes) the task production and consumption.
The produced task may be run by the same thread that called this method.
- Specified by:
produce
in interfaceExecutionStrategy
- See Also:
ExecutionStrategy.dispatch()
-
dispatch
public void dispatch()
Description copied from interface:ExecutionStrategy
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)- Specified by:
dispatch
in interfaceExecutionStrategy
- See Also:
ExecutionStrategy.produce()
-
-