Class FilteredSharedChannelOutputWrapper

java.lang.Object
org.jcsp.lang.ChannelOutputWrapper
org.jcsp.util.filter.FilteredChannelOutputWrapper
org.jcsp.util.filter.FilteredSharedChannelOutputWrapper
All Implemented Interfaces:
ChannelOutput, Poisonable, SharedChannelOutput, FilteredChannelOutput, FilteredSharedChannelOutput, WriteFiltered
public class FilteredSharedChannelOutputWrapper extends FilteredChannelOutputWrapper implements FilteredSharedChannelOutput
This is wrapper for a SharedChannelOutput that adds write filtering. Instances of this class can be safely used by multiple concurrent processes.

  • Field Details

    • synchObject

      private Object synchObject
      The synchronization object to protect the writers from each other when they read data or update the write filters.

  • Constructor Details

    • FilteredSharedChannelOutputWrapper

      public FilteredSharedChannelOutputWrapper(SharedChannelOutput out)
      Constructs a new wrapper for the given channel output end.
      Parameters:
      out - the existing channel end.

  • Method Details

    • write

      public void write(Object data)
      Description copied from class: ChannelOutputWrapper
      Writes a value to the channel.
      Specified by:
      write in interface ChannelOutput
      Overrides:
      write in class FilteredChannelOutputWrapper
      Parameters:
      data - the value to write.
      See Also:

    • addWriteFilter

      public void addWriteFilter(Filter filter)
      Description copied from interface: WriteFiltered
      Installs a write filter defining a transformation to be applied by the write 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:
      addWriteFilter in interface WriteFiltered
      Overrides:
      addWriteFilter in class FilteredChannelOutputWrapper
      Parameters:
      filter - the filter to be installed; may not be null.

    • addWriteFilter

      public void addWriteFilter(Filter filter, int index)
      Description copied from interface: WriteFiltered
      Installs a write filter defining a transformation to be applied by the write 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:
      addWriteFilter in interface WriteFiltered
      Overrides:
      addWriteFilter in class FilteredChannelOutputWrapper
      Parameters:
      filter - the filter to be installed; may not be null.
      index - the zero based index; may not be negative.

    • removeWriteFilter

      public void removeWriteFilter(Filter filter)
      Description copied from interface: WriteFiltered
      Removes the first write 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:
      removeWriteFilter in interface WriteFiltered
      Overrides:
      removeWriteFilter in class FilteredChannelOutputWrapper
      Parameters:
      filter - the filter to be removed; may not be null.

    • removeWriteFilter

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

    • getWriteFilter

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

    • getWriteFilterCount

      public int getWriteFilterCount()
      Description copied from interface: WriteFiltered
      Returns the number of write filters currently installed.
      Specified by:
      getWriteFilterCount in interface WriteFiltered
      Overrides:
      getWriteFilterCount in class FilteredChannelOutputWrapper