Package org.ojalgo.netio
Class ReaderWriterBuilder<F,B extends ReaderWriterBuilder<F,B>>
- java.lang.Object
-
- org.ojalgo.netio.ReaderWriterBuilder<F,B>
-
- Direct Known Subclasses:
FromFileReader.Builder
,ToFileWriter.Builder
abstract class ReaderWriterBuilder<F,B extends ReaderWriterBuilder<F,B>> extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private static java.util.concurrent.ExecutorService
EXECUTOR
private java.util.concurrent.ExecutorService
myExecutor
private F[]
myFiles
private java.lang.String
myManagerName
private java.util.function.IntSupplier
myParallelism
private int
myQueueCapacity
private Throughput
myStatisticsCollector
-
Constructor Summary
Constructors Constructor Description ReaderWriterBuilder(F[] files)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) static java.util.concurrent.ExecutorService
executor()
B
executor(java.util.concurrent.ExecutorService executor)
(package private) java.util.concurrent.ExecutorService
getExecutor()
(package private) F[]
getFiles()
(package private) int
getParallelism()
(package private) int
getQueueCapacity()
(package private) Throughput
getStatisticsCollector()
(package private) boolean
isStatisticsCollector()
B
manager(java.lang.String name)
Will create a JMX bean, with the given name, that keeps track of the reader/writer's throughput.(package private) <T> java.util.concurrent.BlockingQueue<T>
newQueue(int capacity)
B
parallelism(int parallelism)
B
parallelism(java.util.function.IntSupplier parallelism)
B
queue(int capacity)
B
statistics(Throughput collector)
-
-
-
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)
-
-