Class ReaderWriterBuilder<F,​B extends ReaderWriterBuilder<F,​B>>

    • Field Detail

      • EXECUTOR

        private static volatile java.util.concurrent.ExecutorService EXECUTOR
      • myExecutor

        private java.util.concurrent.ExecutorService myExecutor
      • myFiles

        private final F[] myFiles
      • myManagerName

        private java.lang.String myManagerName
      • myParallelism

        private java.util.function.IntSupplier myParallelism
      • myQueueCapacity

        private int myQueueCapacity
      • myStatisticsCollector

        private Throughput myStatisticsCollector
    • Constructor Detail

      • ReaderWriterBuilder

        ReaderWriterBuilder​(F[] files)
    • Method Detail

      • executor

        static java.util.concurrent.ExecutorService executor()
      • executor

        public B executor​(java.util.concurrent.ExecutorService executor)
      • manager

        public B manager​(java.lang.String name)
        Will create a JMX bean, with the given name, that keeps track of the reader/writer's throughput.
      • parallelism

        public B parallelism​(int parallelism)
      • parallelism

        public B parallelism​(java.util.function.IntSupplier parallelism)
      • queue

        public B queue​(int capacity)
      • statistics

        public B statistics​(Throughput collector)
      • getExecutor

        java.util.concurrent.ExecutorService getExecutor()
      • getFiles

        F[] getFiles()
      • getParallelism

        int getParallelism()
      • getQueueCapacity

        int getQueueCapacity()
      • getStatisticsCollector

        Throughput getStatisticsCollector()
      • isStatisticsCollector

        boolean isStatisticsCollector()
      • newQueue

        <T> java.util.concurrent.BlockingQueue<T> newQueue​(int capacity)