Package org.jcsp.lang
Class One2AnyConnectionImpl<T>
- java.lang.Object
-
- org.jcsp.lang.One2AnyConnectionImpl<T>
-
- All Implemented Interfaces:
ConnectionWithSharedAltingServer<T>
,One2AnyConnection<T>
class One2AnyConnectionImpl<T> extends java.lang.Object implements One2AnyConnection<T>
This class is an implementation ofOne2AnyConnection
. Each end is safe to be used by one thread at a time.
-
-
Field Summary
Fields Modifier and Type Field Description private One2OneChannel<T>
chanFromServer
private Any2OneChannel<T>
chanSynch
private One2OneChannel<T>
chanToServer
private AltingConnectionClient
client
-
Constructor Summary
Constructors Constructor Description One2AnyConnectionImpl()
Initializes all the attributes to necessary values.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AltingConnectionClient
client()
Returns theAltingConnectionClient
that can be used by a single process at any instance.SharedConnectionServer
server()
Returns aSharedConnectionServer
object for this connection.
-
-
-
Field Detail
-
client
private AltingConnectionClient client
-
chanToServer
private One2OneChannel<T> chanToServer
-
chanFromServer
private One2OneChannel<T> chanFromServer
-
chanSynch
private Any2OneChannel<T> chanSynch
-
-
Method Detail
-
client
public AltingConnectionClient client()
Returns theAltingConnectionClient
that can be used by a single process at any instance. Each call to this method will return the same object reference.- Specified by:
client
in interfaceOne2AnyConnection<T>
- Returns:
- the
AltingConnectionClient
object.
-
server
public SharedConnectionServer server()
Returns aSharedConnectionServer
object for this connection. This method can be called multiple times to return a newSharedConnectionServer
object each time. Any object created can only be used by one process at a time but the set of objects constructed can be used concurrently.- Specified by:
server
in interfaceConnectionWithSharedAltingServer<T>
- Specified by:
server
in interfaceOne2AnyConnection<T>
- Returns:
- a new
SharedConnectionServer
object.
-
-