Uses of Interface
groovyx.gpars.scheduler.Pool

Packages that use Pool

Package	Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Field and Description
private Pool	DataCallbackWithPool.pool

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

Modifier and Type	Method and Description
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.
<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.
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
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>	LazyDataflowVariable.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.
Promise<java.util.List>	Promise.thenForkAndJoin(Pool pool, groovy.lang.Closure<? extends java.lang.Object>... closures) Schedule a set of closures to be executed after data became available on the current promise.
<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

Constructor and Description
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

Modifier and Type	Method and Description
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)
<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)
private Promise<java.util.List>	DataflowExpression.doThenForkAndJoin(PGroup group, Pool pool, groovy.lang.Closure<? extends java.lang.Object>[] closures)
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)
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.
Promise<java.util.List>	DataflowExpression.thenForkAndJoin(Pool pool, groovy.lang.Closure<? extends java.lang.Object>... closures) Schedule a set of closures to be executed after data became available on the current promise.
<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

Modifier and Type	Field and Description
private Pool	ForkingDataflowOperatorActor.threadPool
private Pool	ForkingDataflowSelectorActor.threadPool

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

Constructor and Description
Pipeline(Pool pool, DataflowReadChannel output)

Uses of Pool in groovyx.gpars.dataflow.stream

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

Modifier and Type	Method and Description
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)
<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)
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)
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

Modifier and Type	Field and Description
private Pool	PGroup.threadPool Stores the group actors' thread pool

Methods in groovyx.gpars.group that return Pool

Modifier and Type	Method and Description
Pool	PGroup.getThreadPool()

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

Modifier and Type	Method and Description
static PGroup	PGroupBuilder.createFromPool(Pool pool) Builds a PGroup instance from a Pool instance

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

Constructor and Description
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

Modifier and Type	Class and Description
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

Uses of Pool in groovyx.gpars.util

Fields in groovyx.gpars.util declared as Pool

Modifier and Type	Field and Description
private Pool	AsyncMessagingCore.threadPool

Methods in groovyx.gpars.util that return Pool

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Constructor and Description
AsyncMessagingCore(Pool threadPool)