Class ShardedConsumer.PowerOf2ShardedConsumer<T>

    • Field Detail

      • myConsumers

        private final java.util.function.Consumer<T>[] myConsumers
      • myDistributor

        private final java.util.function.ToIntFunction<T> myDistributor
      • myIndexMask

        private final int myIndexMask
    • Constructor Detail

      • PowerOf2ShardedConsumer

        PowerOf2ShardedConsumer​(java.util.function.ToIntFunction<T> distributor,
                                java.util.function.Consumer<T>[] consumers)
    • Method Detail

      • write

        public void write​(T item)
        Description copied from interface: AutoConsumer
        Write the item to the consumer.
        Parameters:
        item - The item to be written