Uses of Interface
groovyx.gpars.dataflow.SelectableChannel

Packages that use SelectableChannel

Package	Description
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.impl
groovyx.gpars.dataflow.stream
groovyx.gpars.group

Uses of SelectableChannel in groovyx.gpars.dataflow

Subinterfaces of SelectableChannel in groovyx.gpars.dataflow

Modifier and Type	Interface and Description
interface	DataflowChannel<T> A common interface for all dataflow variables, streams or queues
interface	DataflowReadChannel<T> A common interface for all dataflow variables, streams or queues
interface	Promise<T> A unifying future-like interface to dataflow variables, asynchronous functions and active objects.

Classes in groovyx.gpars.dataflow that implement SelectableChannel

Modifier and Type	Class and Description
class	DataflowQueue<T> Represents a thread-safe data flow stream.
class	DataflowVariable<T> Represents a thread-safe single-assignment, multi-read variable.
static class	DataflowVariable.RemoteDataflowVariable<T>
class	LazyDataflowVariable<T> Represents a thread-safe single-assignment, multi-read variable with delayed initialization.
class	SyncDataflowQueue<T> Represents a thread-safe synchronous data flow stream.
(package private) class	SyncDataflowStreamReadAdapter<T> Provides a special implementation of DataflowStreamReadAdapter, which cooperates with SyncDataflowBroadcast subscription and un-subscription mechanism.
class	SyncDataflowVariable<T> A synchronous variant of DataflowVariable, which blocks the writer as well as the readers.

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

Modifier and Type	Method and Description
static Select<?>	Dataflow.select(SelectableChannel<?>... channels) Creates a select using the default dataflow parallel group.

Method parameters in groovyx.gpars.dataflow with type arguments of type SelectableChannel

Modifier and Type	Method and Description
static Select<?>	Dataflow.select(java.util.List<SelectableChannel> channels) Creates a select using the default dataflow parallel group.

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

Constructor and Description
Select(PGroup pGroup, SelectableChannel<? extends T>... channels)

Constructor parameters in groovyx.gpars.dataflow with type arguments of type SelectableChannel

Constructor and Description
Select(PGroup pGroup, java.util.List<SelectableChannel<? extends T>> channels)

Uses of SelectableChannel in groovyx.gpars.dataflow.expression

Classes in groovyx.gpars.dataflow.expression that implement SelectableChannel

Modifier and Type	Class and Description
class	DataflowComplexExpression<T> Provides the infrastructure for dataflow expressions to evaluate arguments.
class	DataflowExpression<T> The base class for all dataflow elements.
private static class	DataflowExpression.TransformMany<V>
private static class	DataflowExpression.TransformOne<V>
class	DataflowGetPropertyExpression<T> A DFE, which evaluates a property when the receiver becomes available
class	DataflowInvocationExpression A dataflow expression, which invokes a method after the receiver as well as all the arguments become available
class	RemoteDataflowExpression<T>

Uses of SelectableChannel in groovyx.gpars.dataflow.impl

Fields in groovyx.gpars.dataflow.impl declared as SelectableChannel

Modifier and Type	Field and Description
private SelectableChannel<? extends T>	SelectCallback.channel

Fields in groovyx.gpars.dataflow.impl with type parameters of type SelectableChannel

Modifier and Type	Field and Description
private java.util.List<SelectableChannel<? extends T>>	SelectBase.channels

Methods in groovyx.gpars.dataflow.impl with parameters of type SelectableChannel

Modifier and Type	Method and Description
(package private) void	SelectBase.boundNotification(int index, SelectableChannel<? extends T> channel) Invoked by the SelectCallback instances, potentially concurrently to inform about new values being available for read from channels.
private void	SelectBase.disableDFV(int currentPosition, SelectableChannel<? extends T> channel) Sets the flag in the disabledDFVs array, if the channel is a DFV

Constructors in groovyx.gpars.dataflow.impl with parameters of type SelectableChannel

Constructor and Description
SelectCallback(java.lang.Object owner, int index, SelectableChannel<? extends T> channel)

Constructor parameters in groovyx.gpars.dataflow.impl with type arguments of type SelectableChannel

Constructor and Description
SelectBase(PGroup pGroup, java.util.List<SelectableChannel<? extends T>> channels) Stores the input channel and registers for the wheneverBound() event on each

Uses of SelectableChannel in groovyx.gpars.dataflow.stream

Classes in groovyx.gpars.dataflow.stream that implement SelectableChannel

Modifier and Type	Class and Description
class	DataflowStreamReadAdapter<T> Adapts a DataflowStream to accommodate for the DataflowReadChannel interface.

Uses of SelectableChannel in groovyx.gpars.group

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

Modifier and Type	Method and Description
Select	PGroup.select(SelectableChannel... channels) Creates a select using the current parallel group.

Method parameters in groovyx.gpars.group with type arguments of type SelectableChannel

Modifier and Type	Method and Description
Select	PGroup.select(java.util.List<SelectableChannel> channels) Creates a select using the current parallel group.