Uses of Interface
groovyx.gpars.scheduler.Pool

Packages that use Pool

groovyx.gpars.agent
groovyx.gpars.dataflow	This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
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.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	DataflowExpression.whenBound(Pool pool, groovy.lang.Closure closure) Schedule closure to be executed by pooled actor after data becomes available It is important to notice that even if data already available the execution of closure will not happen immediately but will be scheduled.
void	DataflowQueue.whenBound(Pool pool, groovy.lang.Closure closure) Schedule closure to be executed by pooled actor after data becomes available It is important to notice that even if data already available the execution of closure will not happen immediately but will be scheduled.
void	DataflowReadChannel.whenBound(Pool pool, groovy.lang.Closure closure) Schedule closure to be executed by pooled actor after data becomes available It is important to notice that even if data already available the execution of closure will not happen immediately but will be scheduled.
void	Promise.whenBound(Pool pool, groovy.lang.Closure closure) Schedule closure to be executed by pooled actor after data becomes available It is important to notice that even if data already available the execution of closure will not happen immediately but will be scheduled.

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

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

Uses of Pool in groovyx.gpars.dataflow.stream

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

void	DataflowStreamReadAdapter.whenBound(Pool pool, groovy.lang.Closure closure) Schedule closure to be executed by pooled actor after data becomes available It is important to notice that even if data already available the execution of closure will not happen immediately but will be scheduled.

Uses of Pool in groovyx.gpars.group

Classes in groovyx.gpars.group that implement Pool

class	DefaultPGroup Provides logical grouping for actors, agents and dataflow tasks and operators.
class	NonDaemonPGroup Provides logical grouping for actors, agents and dataflow tasks and operators.
class	groovyx.gpars.group.PGroup

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

DefaultPGroup(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

(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 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 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)