DataCallback (org.codehaus.gpars)

Overview

Package

Class

Deprecated

Index

Help

org.codehaus.gpars

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

groovyx.gpars.dataflow
[Java] Class DataCallback

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.actor.impl.MessageStream
          groovyx.gpars.dataflow.DataCallback

public final class DataCallback
extends MessageStream

A helper class enabling the 'whenBound()' or 'getValAsync' functionality of a DataflowVariable and DataflowQueue, as well as 'sendAndContinue()' on actors. A task that waits asynchronously on the DFV to be bound. Once the DFV is bound, upon receiving the message the actor runs the supplied closure / code with the DFV value as a parameter.

Authors:: Vaclav Pech, Alex Tkachman Date: Sep 13, 2009

Field Summary
`private groovy.lang.Closure`	`code`
`private PGroup`	`parallelGroup`
`private static long`	`serialVersionUID`

Fields inherited from class MessageStream
serialVersionUID

Fields inherited from class WithSerialId
serialHandle, serialVersionUID

Constructor Summary
`DataCallback(groovy.lang.Closure code, PGroup pGroup)` Sends a message back to the DataCallback.

Method Summary
`MessageStream`	`send(java.lang.Object message)`

Methods inherited from class MessageStream
call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndWait, sendAndWait, sendAndWait

Methods inherited from class WithSerialId
createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace

Field Detail

code

private final groovy.lang.Closure code

parallelGroup

private final PGroup parallelGroup

serialVersionUID

private static final long serialVersionUID

Constructor Detail

DataCallback

public DataCallback(groovy.lang.Closure code, PGroup pGroup)

Sends a message back to the DataCallback. Will schedule processing the internal closure with the thread pool Registers its parallel group with DataflowExpressions for nested 'whenBound' handlers to use the same group.

Method Detail

send

@java.lang.Override}
}
public MessageStream send(java.lang.Object message)