groovyx.gpars.dataflow
[Java] Class DataflowBroadcast

java.lang.Object
  groovyx.gpars.dataflow.stream.DataflowStreamWriteAdapter
      groovyx.gpars.dataflow.DataflowBroadcast

public final class DataflowBroadcast
extends DataflowStreamWriteAdapter

Offers a deterministic one-to-many and many-to-many messaging alternative to DataflowQueue. Internally it wraps a DataflowStream class with a DataflowStreamWriteAdapter and so synchronizes all writes to the underlying stream allowing multiple threads accessing the stream concurrently. On demand through the createReadChannel() method it will return an DataflowReadChannel through which the reader will receive all messages written to the channel since then.

Typical use:

 DataflowWriteChannel broadcastStream = new DataflowBroadcast()
 DataflowReadChannel stream1 = broadcastStream.createReadChannel()
 DataflowReadChannel stream2 = broadcastStream.createReadChannel()
 broadcastStream << 'Message'
 assert stream1.val == stream2.val
 

Parameters:

- The type of messages to pass through the stream

Authors:

Vaclav Pech

DataflowBroadcast

public DataflowBroadcast()

createReadChannel

public DataflowReadChannel createReadChannel()

toString

@java.lang.SuppressWarnings}
}
@java.lang.Override}
public java.lang.String toString()

Copyright © 2008–2013 Václav Pech. All Rights Reserved.