Class FilteredSharedChannelInputWrapper

java.lang.Object
org.jcsp.lang.ChannelInputWrapper
org.jcsp.util.filter.FilteredChannelInputWrapper
org.jcsp.util.filter.FilteredSharedChannelInputWrapper
All Implemented Interfaces:
ChannelInput, Poisonable, SharedChannelInput, FilteredChannelInput, FilteredSharedChannelInput, ReadFiltered
public class FilteredSharedChannelInputWrapper extends FilteredChannelInputWrapper implements FilteredSharedChannelInput
This is wrapper for a SharedChannelInput that adds read filtering. Instances of this class can be safely used by multiple concurrent processes.

  • Field Details

    • synchObject

      private Object synchObject
      The object used for synchronization by the methods here to protect the readers from each other when manipulating the filters and reading data.

  • Constructor Details

    • FilteredSharedChannelInputWrapper

      public FilteredSharedChannelInputWrapper(SharedChannelInput in)
      Constructs a new wrapper for the given channel input end.
      Parameters:
      in - the existing channel end.

  • Method Details

    • read

      public Object read()
      Description copied from class: ChannelInputWrapper
      Reads a value from the channel.
      Specified by:
      read in interface ChannelInput
      Overrides:
      read in class FilteredChannelInputWrapper
      Returns:
      the value read.
      See Also:

    • addReadFilter

      public void addReadFilter(Filter filter)
      Description copied from interface: ReadFiltered
      Installs a read filter defining a transformation to be applied by the read method of the channel end. The filter will be appended to the end of the current list, making it the last to be applied.
      Specified by:
      addReadFilter in interface ReadFiltered
      Overrides:
      addReadFilter in class FilteredChannelInputWrapper
      Parameters:
      filter - the filter to be installed; may not be null.

    • addReadFilter

      public void addReadFilter(Filter filter, int index)
      Description copied from interface: ReadFiltered
      Installs a read filter defining a transformation to be applied by the read method of the channel end at a specific index. If there is already a filter at that index position the existing filters are shifted to make room. If the index is greater than the number of filters already installed the filter is placed at the end.
      Specified by:
      addReadFilter in interface ReadFiltered
      Overrides:
      addReadFilter in class FilteredChannelInputWrapper
      Parameters:
      filter - the filter to be installed; may not be null.
      index - the zero based index; may not be negative.

    • removeReadFilter

      public void removeReadFilter(Filter filter)
      Description copied from interface: ReadFiltered
      Removes the first read filter (lowest index) matching the filter given as a parameter. The filter removed, r, will satisfy the condition r.equals (filter). The remaining filters are shifted to close the gap in the index allocation.
      Specified by:
      removeReadFilter in interface ReadFiltered
      Overrides:
      removeReadFilter in class FilteredChannelInputWrapper
      Parameters:
      filter - the filter to be removed; may not be null.

    • removeReadFilter

      public void removeReadFilter(int index)
      Description copied from interface: ReadFiltered
      Removes the read filter installed at the given index. The remaining filters are shifted to close the gap in the index allocation.
      Specified by:
      removeReadFilter in interface ReadFiltered
      Overrides:
      removeReadFilter in class FilteredChannelInputWrapper
      Parameters:
      index - zero-based index of the filter to be removed.

    • getReadFilter

      public Filter getReadFilter(int index)
      Description copied from interface: ReadFiltered
      Returns the read filter installed at the given index.
      Specified by:
      getReadFilter in interface ReadFiltered
      Overrides:
      getReadFilter in class FilteredChannelInputWrapper
      Parameters:
      index - zero-based index of the filter to return.
      Returns:
      the filter at that position.

    • getReadFilterCount

      public int getReadFilterCount()
      Description copied from interface: ReadFiltered
      Returns the number of read filters currently installed.
      Specified by:
      getReadFilterCount in interface ReadFiltered
      Overrides:
      getReadFilterCount in class FilteredChannelInputWrapper