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 and Description
static class	ProduceConsume.Factory

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.ExecutionStrategy

ExecutionStrategy.DefaultExecutionStrategyFactory, ExecutionStrategy.Producer, ExecutionStrategy.Rejectable

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProduceConsume

public ProduceConsume(ExecutionStrategy.Producer producer,
                      Executor executor)

Method Detail

execute

public void execute()

Description copied from interface: ExecutionStrategy

Initiates (or resumes) the task production and execution.

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

Specified by:

execute in interface ExecutionStrategy

See Also:

ExecutionStrategy.dispatch()

dispatch

public void dispatch()

Description copied from interface: 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.

Specified by:

dispatch in interface ExecutionStrategy

See Also:

ExecutionStrategy.execute()

run

public void run()

Specified by:

run in interface Runnable