Package | Description |
---|---|
agi.foundation.infrastructure.threading |
Contains types used to perform and manage calculations among multiple threads of execution.
|
Modifier and Type | Method and Description |
---|---|
static <TParameter> |
ThreadedCalculation.BodyCallback.of(ThreadedCalculation.BodyCallback.Function<TParameter> f)
Create a delegate for the given interface.
|
static <TParameter> |
ThreadedCalculation.BodyCallback.of(ThreadedCalculation.BodyCallback.Function<TParameter> f,
Class<?> targetClass,
String methodName,
Class<?>... methodParameterClasses)
Create a delegate for the given interface.
|
static <TParameter> |
ThreadedCalculation.BodyCallback.of(ThreadedCalculation.BodyCallback.Function<TParameter> f,
Object targetObject,
String methodName,
Class<?>... methodParameterClasses)
Create a delegate for the given interface.
|
Modifier and Type | Method and Description |
---|---|
static <TParameter> |
ThreadedCalculation._for(int start,
int stop,
TParameter parameter,
ITrackCalculationProgress tracker,
ThreadedCalculation.BodyCallback<TParameter> body)
A 'for' loop that is parallelized among multiple threads according to the
ThreadingPolicy active in the calling thread. |