- resetCounters() - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Resets failedSubmission, succeeded and failed counter.
- resetCounters() - Method in class javafixes.concurrency.Runner
-
Resets failedSubmission, failedToStart, succeeded and failed counter.
- ReusableCountLatch - Class in javafixes.concurrency
-
A synchronization aid that allows one or more threads to wait until
a set of operations being performed in other threads completes.
- ReusableCountLatch(int) - Constructor for class javafixes.concurrency.ReusableCountLatch
-
Constructs a ReusableCountLatch initialized with the given count.
- ReusableCountLatch() - Constructor for class javafixes.concurrency.ReusableCountLatch
-
Constructs a ReusableCountLatch with initial count set to 0.
- right(R) - Static method in class javafixes.object.Either
-
Generates
Either of type
Right wrapping the provided value
- run() - Method in interface javafixes.common.function.Task
-
Executes a task or throws an exception if unable to do so.
- run(Callable<T>) - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Schedules a Callable for immediate execution.
- run(Task) - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Schedules a
Task for immediate execution
It might be executed later though if the
ScheduledExecutorService has no available threads
or more tasks are queued for execution before this task.
- run(ShutdownAwareCallable<T>) - Method in class javafixes.concurrency.Runner
-
- run(ShutdownAwareTask) - Method in class javafixes.concurrency.Runner
-
Schedules a
ShutdownAwareTask for immediate execution
It might be executed later though if the
ScheduledExecutorService has no available threads
or more tasks are queued for execution before this task.
- run(ShutdownInfo) - Method in interface javafixes.concurrency.ShutdownAwareTask
-
Executes a task or throws an exception if unable to do so.
- runCallable(Callable<T>) - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Schedules a Callable for immediate execution.
- runCallable(ShutdownAwareCallable<T>) - Method in class javafixes.concurrency.Runner
-
- runCallableIn(long, TimeUnit, Callable<T>) - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Schedules a Callable for delayed execution.
- runCallableIn(long, TimeUnit, ShutdownAwareCallable<T>) - Method in class javafixes.concurrency.Runner
-
- runIn(long, TimeUnit, Callable<T>) - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Schedules a Callable for delayed execution.
- runIn(long, TimeUnit, Task) - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Schedules a
Task for delayed execution
The delay is defined using the
delay and
unit parameters.
- runIn(long, TimeUnit, ShutdownAwareCallable<T>) - Method in class javafixes.concurrency.Runner
-
- runIn(long, TimeUnit, ShutdownAwareTask) - Method in class javafixes.concurrency.Runner
-
Schedules a
ShutdownAwareTask for delayed execution
The delay is defined using the
delay and
unit parameters.
- Runner - Class in javafixes.concurrency
-
An ScheduledExecutorService alternative
that allows you to monitor the number of submitted, failed and succeeded task, plus has the
ability to wait until all tasks are completed (without the need of shutting it down)
= wait until there are no scheduled or running tasks.
- Runner(int) - Constructor for class javafixes.concurrency.Runner
-
Constructs a runner with specific number of executor thread.
- runner(int) - Static method in class javafixes.concurrency.Runner
-
Factory method to create a Runner.
- runRunnable(Runnable) - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Schedules a Runnable for immediate execution
It might be executed later though if the ScheduledExecutorService has no available threads
or more tasks are queued for execution before this task.
- runRunnableIn(long, TimeUnit, Runnable) - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Schedules a Runnable for delayed execution
The delay is defined using the delay and unit parameters.
- runTask(Task) - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Schedules a
Task for immediate execution
It might be executed later though if the
ScheduledExecutorService has no available threads
or more tasks are queued for execution before this task.
- runTask(ShutdownAwareTask) - Method in class javafixes.concurrency.Runner
-
Schedules a
ShutdownAwareTask for immediate execution
It might be executed later though if the
ScheduledExecutorService has no available threads
or more tasks are queued for execution before this task.
- runTaskIn(long, TimeUnit, Task) - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Schedules a
Task for delayed execution
The delay is defined using the
delay and
unit parameters.
- runTaskIn(long, TimeUnit, ShutdownAwareTask) - Method in class javafixes.concurrency.Runner
-
Schedules a
ShutdownAwareTask for delayed execution
The delay is defined using the
delay and
unit parameters.
- waitTillDone() - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Causes the current thread to wait until there are no unfinished tasks,
unless the thread is interrupted.
- waitTillDone(long, TimeUnit) - Method in class javafixes.concurrency.MonitoringTaskSubmitter
-
Causes the current thread to wait until there are no unfinished tasks,
unless the thread is interrupted.
- waitTillDone() - Method in class javafixes.concurrency.Runner
-
- waitTillZero() - Method in class javafixes.concurrency.ReusableCountLatch
-
Causes the current thread to wait until the latch has counted down to
zero, unless the thread is interrupted.
- waitTillZero(long, TimeUnit) - Method in class javafixes.concurrency.ReusableCountLatch
-
Causes the current thread to wait until the latch has counted down to
zero, unless the thread is interrupted,
or the specified waiting time elapses.
- wasShutdownTriggered() - Method in class javafixes.concurrency.Runner
-
Returns true if any shutdown operation has been called on this Runner.
- wasShutdownTriggered() - Method in interface javafixes.concurrency.ShutdownInfo
-
- withDisposeFunction(Consumer<T>) - Method in class javafixes.object.changing.DerivedValue
-
- withDisposeFunction(Optional<Consumer<T>>) - Method in class javafixes.object.changing.DerivedValue
-
- withDisposeFunction(Consumer<T>) - Method in class javafixes.object.changing.DynamicValue
-
- withDisposeFunction(Optional<Consumer<T>>) - Method in class javafixes.object.changing.DynamicValue
-
- withDisposeFunction(Consumer<T>) - Method in class javafixes.object.changing.MutableValue
-
Creates a copy of current MutableValue with defined dispose function
- withDisposeFunction(Optional<Consumer<T>>) - Method in class javafixes.object.changing.MutableValue
-
Creates a copy of current MutableValue with new dispose function if Optional dispose function is defined
and without a dispose function if the Optional dispose function is undefined
- withDoUpdateIfNewAndOldValueAreEqual(boolean) - Method in class javafixes.object.changing.DerivedValue
-
- withNoDisposeFunction() - Method in class javafixes.object.changing.DerivedValue
-
- withNoDisposeFunction() - Method in class javafixes.object.changing.DynamicValue
-
- withNoDisposeFunction() - Method in class javafixes.object.changing.MutableValue
-
Creates a copy of current MutableValue with dispose function being removed
- withNoOnValueSetFunction() - Method in class javafixes.object.changing.DerivedValue
-
- withNoOnValueSetFunction() - Method in class javafixes.object.changing.DynamicValue
-
- withNoOnValueSetFunction() - Method in class javafixes.object.changing.MutableValue
-
Creates a copy of current MutableValue with on value set function being removed
- withNoValueName() - Method in class javafixes.object.changing.DerivedValue
-
- withNoValueName() - Method in class javafixes.object.changing.DynamicValue
-
- withNoValueName() - Method in class javafixes.object.changing.MutableValue
-
Creates a copy of current MutableValue with value name being removed
- withOnValueSetFunction(Consumer<T>, boolean) - Method in class javafixes.object.changing.DerivedValue
-
- withOnValueSetFunction(Optional<Consumer<T>>, boolean) - Method in class javafixes.object.changing.DerivedValue
-
- withOnValueSetFunction(Consumer<T>, boolean) - Method in class javafixes.object.changing.DynamicValue
-
- withOnValueSetFunction(Optional<Consumer<T>>, boolean) - Method in class javafixes.object.changing.DynamicValue
-
- withOnValueSetFunction(Consumer<T>, boolean) - Method in class javafixes.object.changing.MutableValue
-
Creates a copy of current MutableValue with defined function applied to each new wrapped value
- withOnValueSetFunction(Optional<Consumer<T>>, boolean) - Method in class javafixes.object.changing.MutableValue
-
Creates a copy of current MutableValue with new on value set function if Optional on value set function is defined
and without an on value set function if the Optional on value set function is undefined
- withValueName(String) - Method in class javafixes.object.changing.DerivedValue
-
- withValueName(Optional<String>) - Method in class javafixes.object.changing.DerivedValue
-
- withValueName(String) - Method in class javafixes.object.changing.DynamicValue
-
- withValueName(Optional<String>) - Method in class javafixes.object.changing.DynamicValue
-
- withValueName(String) - Method in class javafixes.object.changing.MutableValue
-
Creates a copy of current MutableValue with defined value name
- withValueName(Optional<String>) - Method in class javafixes.object.changing.MutableValue
-
Creates a copy of current MutableValue with new value name if Optional name is defined
and without a value name if the Optional name is undefined
- WrappedException - Exception in javafixes.concurrency
-
- WrappedException(String, Throwable) - Constructor for exception javafixes.concurrency.WrappedException
-
- WrappedException(Throwable) - Constructor for exception javafixes.concurrency.WrappedException
-
- write(int) - Method in class javafixes.io.ByteCollectingOutputStream
-
- write(byte[], int, int) - Method in class javafixes.io.ByteCollectingOutputStream
-
- writeIntoTempFile(InputStream) - Static method in class javafixes.io.InputStreamUtil
-
- writeTo(OutputStream) - Method in class javafixes.io.ByteCollectingOutputStream
-