Class ThreadLocalBatchData<D>


  • public class ThreadLocalBatchData<D>
    extends PersistentThreadLocal<java.util.List<D>>
    Convenience class for storing collections of thread-local data.
    Since:
    1.6
    Author:
    Sina Madani
    • Constructor Detail

      • ThreadLocalBatchData

        public ThreadLocalBatchData()
      • ThreadLocalBatchData

        public ThreadLocalBatchData​(int numThreads)
    • Method Detail

      • ofEntry

        public static <K,​V> ThreadLocalBatchData<java.util.Map.Entry<? extends K,​? extends V>> ofEntry()
      • ofEntry

        public static <K,​V> ThreadLocalBatchData<java.util.Map.Entry<? extends K,​? extends V>> ofEntry​(int parallelism)
      • getBatch

        public java.util.Collection<D> getBatch()
      • addElement

        public void addElement​(D value)
      • removeElement

        public void removeElement​(D value)
      • updateElement

        public void updateElement​(D oldValue,
                                  D newValue)
      • getAndThen

        protected void getAndThen​(java.util.function.Consumer<java.util.List<D>> dataConsumer)