Package org.jcsp.lang

Class PoisonableBufferedOne2OneChannel<T>

    • Field Detail

      • data

        private final ChannelDataStore<T> data
        The ChannelDataStore used to store the data for the channel
      • rwMonitor

        private final java.lang.Object rwMonitor
      • immunity

        private int immunity
      • poisonStrength

        private int poisonStrength
    • Constructor Detail

      • PoisonableBufferedOne2OneChannel

        public PoisonableBufferedOne2OneChannel​(ChannelDataStore<T> data,
                                                int _immunity)
        Constructs a new BufferedOne2OneChannel with the specified ChannelDataStore.
        Parameters:
        data - the ChannelDataStore used to store the data for the channel
    • Method Detail

      • isPoisoned

        private boolean isPoisoned()
      • read

        public T read()
        Reads an Object from the channel.
        Specified by:
        read in interface ChannelInternals<T>
        Returns:
        the object read from the channel.
      • write

        public void write​(T value)
        Writes an Object to the channel.
        Specified by:
        write in interface ChannelInternals<T>
        Parameters:
        value - the object to write to the channel.
      • readerEnable

        public boolean readerEnable​(Alternative alt)
        turns on Alternative selection for the channel. Returns true if the channel has data that can be read immediately.

        Note: this method should only be called by the Alternative class

        Specified by:
        readerEnable in interface ChannelInternals<T>
        Parameters:
        alt - the Alternative class which will control the selection
        Returns:
        true if the channel has data that can be read, else false
      • readerDisable

        public boolean readerDisable()
        turns off Alternative selection for the channel. Returns true if the channel contained data that can be read.

        Note: this method should only be called by the Alternative class

        Specified by:
        readerDisable in interface ChannelInternals<T>
        Returns:
        true if the channel has data that can be read, else false
      • readerPending

        public boolean readerPending()
        Returns whether there is data pending on this channel.

        Note: if there is, it won't go away until you read it. But if there isn't, there may be some by the time you check the result of this method.

        This method is provided for convenience. Its functionality can be provided by Pri Alting the channel against a SKIP guard, although at greater run-time and syntactic cost. For example, the following code fragment:

           if (c.pending ()) {
             Object x = c.read ();
             ...  do something with x
           } else (
             ...  do something else
           }
         
        is equivalent to:
           if (c_pending.priSelect () == 0) {
             Object x = c.read ();
             ...  do something with x
           } else (
             ...  do something else
         }
         
        where earlier would have had to have been declared:
         final Alternative c_pending =
           new Alternative (new Guard[] {c, new Skip ()});
         
        Specified by:
        readerPending in interface ChannelInternals<T>
        Returns:
        state of the channel.
      • in

        public AltingChannelInput<T> in()
        Returns the AltingChannelInput to use for this channel. As BufferedOne2OneChannel implements AltingChannelInput itself, this method simply returns a reference to the object that it is called on.
        Specified by:
        in in interface One2OneChannel<T>
        Returns:
        the AltingChannelInput object to use for this channel.
      • out

        public ChannelOutput<T> out()
        Returns the ChannelOutput object to use for this channel. As BufferedOne2OneChannel implements ChannelOutput itself, this method simply returns a reference to the object that it is called on.
        Specified by:
        out in interface One2OneChannel<T>
        Returns:
        the ChannelOutput object to use for this channel.