Uses of Interface
groovyx.gpars.scheduler.Pool

Packages that use Pool

groovyx.gpars	This package holds classes for asynchronous collection processing.
groovyx.gpars.agent
groovyx.gpars.dataflow	This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
groovyx.gpars.dataflow.expression
groovyx.gpars.dataflow.operator	This package holds classes representing operators and channels necessary for full dataflow concurrency.
groovyx.gpars.dataflow.stream
groovyx.gpars.group
groovyx.gpars.scheduler	This package holds thread pools / schedulers used by actors and dataflow concurrency.
groovyx.gpars.util	Various utility classes enhancing basic Java concurrency constructs.

Uses of Pool in groovyx.gpars

Methods in groovyx.gpars that return Pool

static Pool

GParsConfig.retrieveDefaultPool() If a pool factory has been set, it will be used to create a new thread pool.

Uses of Pool in groovyx.gpars.agent

Methods in groovyx.gpars.agent with parameters of type Pool

void	AgentCore.attachToThreadPool(Pool threadPool) Sets a new thread pool to be used by the agent

Uses of Pool in groovyx.gpars.dataflow

Fields in groovyx.gpars.dataflow declared as Pool

private Pool

DataCallbackWithPool.pool

Methods in groovyx.gpars.dataflow with parameters of type Pool

void	DataflowQueue.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowReadChannel.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowQueue.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowReadChannel.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
DataflowReadChannel<T>	DataflowQueue.filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowReadChannel.filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure) Creates and attaches a new operator that will filter data using the provided closure
DataflowReadChannel<T>	DataflowQueue.filter(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowReadChannel.filter(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure) Creates and attaches a new operator that will filter data using the provided closure
<V> DataflowReadChannel<V>	DataflowQueue.chainWith(Pool pool, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.chainWith(Pool pool, groovy.lang.Closure<V> closure) Creates and attaches a new operator processing values from the channel
<V> DataflowReadChannel<V>	DataflowQueue.chainWith(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.chainWith(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure) Creates and attaches a new operator processing values from the channel
void	DataflowQueue.choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowReadChannel.choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code) Directs the output to one of the output channels depending on the int result of the provided closure.
void	DataflowQueue.choice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowReadChannel.choice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code) Directs the output to one of the output channels depending on the int result of the provided closure.
void	DataflowQueue.into(Pool pool, DataflowWriteChannel<T> target)
void	DataflowReadChannel.into(Pool pool, DataflowWriteChannel<T> target) Makes the output of the current channel to be an input for the specified channel
void	DataflowQueue.into(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
void	DataflowReadChannel.into(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target) Makes the output of the current channel to be an input for the specified channel
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
void	DataflowQueue.separate(Pool pool, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowReadChannel.separate(Pool pool, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code) Allows the closure to output different values to different output channels.
void	DataflowQueue.separate(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowReadChannel.separate(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code) Allows the closure to output different values to different output channels.
void	DataflowQueue.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowReadChannel.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(Pool pool, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowReadChannel.split(Pool pool, java.util.List<DataflowWriteChannel<T>> targets) Makes the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowReadChannel.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowReadChannel.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets) Makes the output of the current channel to be an input for the specified channels
DataflowReadChannel<T>	DataflowQueue.tap(Pool pool, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowReadChannel.tap(Pool pool, DataflowWriteChannel<T> target) Taps into the pipeline.
DataflowReadChannel<T>	DataflowQueue.tap(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowReadChannel.tap(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target) Taps into the pipeline.
<V> Promise<V>	DataflowQueue.then(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> Promise<V>	DataflowReadChannel.then(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> Promise<V>	Promise.then(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> Promise<V>	DataflowVariable.then(Pool pool, groovy.lang.Closure<V> closure, groovy.lang.Closure<V> errorHandler) Schedule closure to be executed after data becomes available.
<V> Promise<V>	Promise.then(Pool pool, groovy.lang.Closure<V> closure, groovy.lang.Closure<V> errorHandler) Schedule closure to be executed after data becomes available.
<V> void	DataflowQueue.whenBound(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed by pooled actor after data becomes available.
<V> void	DataflowReadChannel.whenBound(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> void	Promise.whenBound(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> void	SyncDataflowStreamReadAdapter.whenBound(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed by pooled actor after data becomes available.

Constructors in groovyx.gpars.dataflow with parameters of type Pool

DataCallbackWithPool(Pool pool, groovy.lang.Closure code)

Uses of Pool in groovyx.gpars.dataflow.expression

Methods in groovyx.gpars.dataflow.expression with parameters of type Pool

void	DataflowExpression.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
DataflowReadChannel<T>	DataflowExpression.filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowExpression.filter(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
<V> DataflowReadChannel<V>	DataflowExpression.chainWith(Pool pool, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.chainWith(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
void	DataflowExpression.choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowExpression.choice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowExpression.into(Pool pool, DataflowWriteChannel<T> target)
void	DataflowExpression.into(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
void	DataflowExpression.separate(Pool pool, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowExpression.separate(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowExpression.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(Pool pool, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowExpression.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
DataflowReadChannel<T>	DataflowExpression.tap(Pool pool, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowExpression.tap(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
<V> Promise<V>	DataflowExpression.then(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> void	DataflowExpression.whenBound(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed by pooled actor after data becomes available.

Uses of Pool in groovyx.gpars.dataflow.operator

Fields in groovyx.gpars.dataflow.operator declared as Pool

private Pool	ForkingDataflowOperatorActor.threadPool
private Pool	ForkingDataflowSelectorActor.threadPool

Constructors in groovyx.gpars.dataflow.operator with parameters of type Pool

Pipeline(Pool pool, DataflowReadChannel output)

Uses of Pool in groovyx.gpars.dataflow.stream

Methods in groovyx.gpars.dataflow.stream with parameters of type Pool

void	DataflowStreamReadAdapter.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
DataflowReadChannel<T>	DataflowStreamReadAdapter.filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowStreamReadAdapter.filter(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.chainWith(Pool pool, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.chainWith(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
void	DataflowStreamReadAdapter.choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowStreamReadAdapter.choice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowStreamReadAdapter.into(Pool pool, DataflowWriteChannel<T> target)
void	DataflowStreamReadAdapter.into(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
void	DataflowStreamReadAdapter.separate(Pool pool, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowStreamReadAdapter.separate(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowStreamReadAdapter.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(Pool pool, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowStreamReadAdapter.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
DataflowReadChannel<T>	DataflowStreamReadAdapter.tap(Pool pool, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowStreamReadAdapter.tap(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
<V> Promise<V>	DataflowStreamReadAdapter.then(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed after data becomes available.
<V> void	DataflowStreamReadAdapter.whenBound(Pool pool, groovy.lang.Closure<V> closure) Schedule closure to be executed by pooled actor after data becomes available.

Uses of Pool in groovyx.gpars.group

Fields in groovyx.gpars.group declared as Pool

private Pool

PGroup.threadPool Stores the group actors' thread pool

Methods in groovyx.gpars.group that return Pool

Pool	PGroup.getThreadPool()

Methods in groovyx.gpars.group with parameters of type Pool

static PGroup

PGroupBuilder.createFromPool(Pool pool) Builds a PGroup instance from a Pool instance

Constructors in groovyx.gpars.group with parameters of type Pool

DefaultPGroup(Pool threadPool)
Creates a group for actors, agents, tasks and operators.

PGroup(Pool threadPool)
Creates a group for actors, agents, tasks and operators.

Uses of Pool in groovyx.gpars.scheduler

Classes in groovyx.gpars.scheduler that implement Pool

class	DefaultPool Represents the actors' thread pool, which performs tasks on behalf of the actors.
class	FJPool Represents the actors' thread pool, which performs tasks on behalf of the actors.
class	ResizeablePool Represents the actors' thread pool, which performs tasks on behalf of the actors.
class	Scheduler Prototype of self-regulated thread pooled scheduler Self regulation happened according to following rules - worker thread, which had nothing to do 10 seconds dies - if no tasks were taken for processing during last 0.5sec new worker starts

Uses of Pool in groovyx.gpars.util

Fields in groovyx.gpars.util declared as Pool

private Pool

AsyncMessagingCore.threadPool

Methods in groovyx.gpars.util that return Pool

Pool	PoolFactory.createPool()
Pool	PoolFactory.createPool(boolean daemon)
Pool	PoolFactory.createPool(boolean daemon, int numberOfThreads)
Pool	PoolFactory.createPool(int numberOfThreads)
(package private) Pool	AsyncMessagingCore.getThreadPool()

Methods in groovyx.gpars.util with parameters of type Pool

void	AsyncMessagingCore.attachToThreadPool(Pool threadPool) Sets a new thread pool to be used by the agent
static <T> void	PAUtils.evaluateArguments(Pool pool, java.lang.Object[] args, int current, java.util.List<java.lang.Object> soFarArgs, DataflowVariable<java.lang.Object> result, groovy.lang.Closure<T> original, boolean pooledThreadFlag) Performs a single step in the evaluation of parameters passed into an asynchronous function

Constructors in groovyx.gpars.util with parameters of type Pool

AsyncMessagingCore(Pool threadPool)