Package org.eclipse.jetty.util.thread.strategy

Class ProduceConsume

java.lang.Object

org.eclipse.jetty.util.thread.strategy.ProduceConsume

All Implemented Interfaces:

Runnable, ExecutionStrategy

public class ProduceConsume
extends Object
implements ExecutionStrategy, 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 enum	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 final Executor	_executor
private final Locker	_locker
private final ExecutionStrategy.Producer	_producer
private ProduceConsume.State	_state
private static final Logger	LOG

Constructor Summary

Constructors

Constructor	Description
ProduceConsume(ExecutionStrategy.Producer producer, Executor executor)

Method Summary

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 Details

LOG

private static final Logger LOG

_locker

private final Locker _locker

_producer

private final ExecutionStrategy.Producer _producer

_executor

private final Executor _executor

_state

private ProduceConsume.State _state

Constructor Details

ProduceConsume

public ProduceConsume(ExecutionStrategy.Producer producer,
 Executor executor)

Method Details

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 Runnable