CSP for Java
(JCSP) 1.0-rc7

jcsp.lang
Class Any2AnyChannel

java.lang.Object
  |
  +--jcsp.lang.Any2AnyChannel
All Implemented Interfaces:
ChannelInput, ChannelOutput, Serializable

public class Any2AnyChannel
extends Object
implements ChannelInput, ChannelOutput, Serializable

This implements an any-to-any object channel, safe for use by many writers and many readers.

Description

Any2AnyChannel is an implementation of a channel which is safe for use by many reading and writing processes. Reading processes compete with each other to use the channel. Writing processes compete with each other to use the channel. Only one reader and one writer will actually be using the channel at any one time. This is taken care of by Any2AnyChannel -- user processes just read from or write to it.

Please note that this is a safely shared channel and not a multicaster. Currently, multicasting has to be managed by writing active processes (see DynamicDelta for an example of broadcasting).

All reading processes and writing processes commit to the channel (i.e. may not back off). This means that the reading processes may not ALT on this channel.

The default semantics of the channel is that of CSP -- i.e. it is zero-buffered and fully synchronised. A reading process must wait for a matching writer and vice-versa.

However, the static create method allows the user to create a channel with a plug-in driver conforming to the ChannelDataStore interface. This allows a variety of different channel semantics to be introduced -- including buffered channels of user-defined capacity (including infinite), overwriting channels (with various overwriting policies) etc.. Standard examples are given in the jcsp.util package, but careful users may write their own.

Other static create methods allows the user to create fully initialised arrays of channels, including plug-ins if required.

Implementation Note and Caution

Fair servicing of readers and writers to this channel depends on the fair servicing of requests to enter a synchronized block (or method) by the underlying Java Virtual Machine (JVM). Java does not specify how threads waiting to synchronize should be handled. Currently, Sun's standard JDKs queue these requests - which is fair. However, there is at least one JVM that puts such competing requests on a stack - which is legal but unfair and can lead to infinite starvation. This is a problem for any Java system relying on good behaviour from synchronized, not just for these any-any channels.

Author:
P.D.Austin and P.H.Welch
See Also:
One2OneChannel, Any2OneChannel, One2AnyChannel, ChannelDataStore, Serialized Form

Field Summary
protected  Object readMonitor
          The monitor on which readers must synchronize
protected  Object rwMonitor
          The monitor synchronising reader and writer on this channel
protected  Object writeMonitor
          The monitor on which writers must synchronize
 
Constructor Summary
Any2AnyChannel()
           
 
Method Summary
static Any2AnyChannel create(ChannelDataStore store)
          Creates a Any2AnyChannel using the specified ChannelDataStore.
static Any2AnyChannel[] create(int n)
          Creates an array of Any2AnyChannel.
static Any2AnyChannel[] create(int n, ChannelDataStore store)
          Creates an array of Any2AnyChannel using the specified ChannelDataStore.
 Object read()
          Reads an Object from the channel.
 void write(Object value)
          Writes an Object to the Channel.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

rwMonitor

protected Object rwMonitor
The monitor synchronising reader and writer on this channel

readMonitor

protected final Object readMonitor
The monitor on which readers must synchronize

writeMonitor

protected final Object writeMonitor
The monitor on which writers must synchronize
Constructor Detail

Any2AnyChannel

public Any2AnyChannel()
Method Detail

read

public Object read()
Reads an Object from the channel.
Specified by:
read in interface ChannelInput
Returns:
the object read from the channel.

write

public void write(Object value)
Writes an Object to the Channel. This method also ensures only one of the writers can actually be writing at any time. All other writers are blocked until it completes the write.
Specified by:
write in interface ChannelOutput
Parameters:
value - The object to write to the Channel.

create

public static Any2AnyChannel[] create(int n)
Creates an array of Any2AnyChannel.
Parameters:
n - the number of channels to create in the array
Returns:
the array of Any2AnyChannel

create

public static Any2AnyChannel create(ChannelDataStore store)
Creates a Any2AnyChannel using the specified ChannelDataStore.
Returns:
the Any2AnyChannel

create

public static Any2AnyChannel[] create(int n,
                                      ChannelDataStore store)
Creates an array of Any2AnyChannel using the specified ChannelDataStore.
Parameters:
n - the number of channels to create in the array
Returns:
the array of Any2AnyChannel

CSP for Java
(JCSP) 1.0-rc7

Submit a bug or feature to jcsp-team@kent.ac.uk
Version 1.0-rc7 of the JCSP API Specification (Copyright 1997-2006 P.D.Austin and P.H.Welch - All Rights Reserved)
Java is a trademark or registered trademark of Sun Microsystems, Inc. in the US and other countries.