ProduceConsume

java.lang.Object
- org.eclipse.jetty.util.thread.strategy.ProduceConsume

All Implemented Interfaces:

java.lang.Runnable, ExecutionStrategy
```
public class ProduceConsume
extends java.lang.Object
implements ExecutionStrategy, java.lang.Runnable
```
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 ProduceConsume.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 ProduceConsume.State`	`_state`
`private static Logger`	`LOG`

Constructor Summary

Constructors
Constructor Description

ProduceConsume(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.
`void`	`run()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 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 ProduceConsume.State _state
```
- Constructor Detail
  - ProduceConsume
```
public ProduceConsume(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 interface ExecutionStrategy
    
    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 interface ExecutionStrategy
    
    See Also:
    
    ExecutionStrategy.produce()
  - run
```
public void run()
```
    Specified by:
    
    run in interface java.lang.Runnable