Groovy Documentation

gpars.dataflow
[Java] Class DataFlowPGroup

java.lang.Object
  groovyx.gpars.group.PGroup
      gpars.dataflow.DataFlowPGroup

public final class DataFlowPGroup
extends PGroup

Groups all dataflow threads, tasks and operators. DataFlow leverages a resizeable pool of non-daemon threads. DataFlowPGroup can be used directly to create and group dataflow actors (threads)

 DataFlowPGroup group = new DataFlowPGroup()
 group.actor {
     ....
 }
 
Authors:
Vaclav Pech, Alex Tkachman Date: Jun 21, 2009


Constructor Summary
DataFlowPGroup(int poolSize)

Creates a default group for dataflow tasks and operators.

 

Constructor Detail

DataFlowPGroup

public DataFlowPGroup(int poolSize)
Creates a default group for dataflow tasks and operators. The actors will share a common non-daemon thread pool.
Parameters:
poolSize - The initial size of the underlying thread pool


 

Groovy Documentation