Class SpscChannelProducer<E>

Type Parameters:
E - element type.
All Implemented Interfaces:
ChannelProducer<E>

public abstract class SpscChannelProducer<E> extends SpscOffHeapFixedSizeRingBuffer implements ChannelProducer<E>
Package Scoped: not part of public API.
  • Field Details

    • pointer

      protected long pointer
  • Constructor Details

    • SpscChannelProducer

      public SpscChannelProducer(ByteBuffer buffer, int capacity, int messageSize)
  • Method Details

    • claim

      public final boolean claim()
      Description copied from interface: ChannelProducer
      Attempt to claim the next element in the channel.
      Specified by:
      claim in interface ChannelProducer<E>
      Returns:
      true if claimed, false if there is insufficient space in the channel.
    • commit

      public final boolean commit()
      Specified by:
      commit in interface ChannelProducer<E>
      Returns:
      true if