Module ojalgo

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

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)