Groovy Documentation

gpars.dataflow
Class DataFlowPGroup

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

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 {
     ....
 }
 
author:
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.
param:
poolSize The initial size of the underlying thread pool


 

Groovy Documentation