I - type if the item models to processT - type or expected TaskResultpublic interface RuleEngineTaskProcessor<I extends ItemModel,T extends TaskResult>
| Modifier and Type | Method and Description |
|---|---|
TaskExecutionFuture<T> |
execute(java.util.List<I> items,
java.util.function.Consumer<java.util.List<I>> taskConsumer)
Process the items in the list in multi-thread mode with provided items consumer
|
TaskExecutionFuture<T> |
execute(java.util.List<I> items,
java.util.function.Consumer<java.util.List<I>> taskConsumer,
long predestroyTimeout)
Process the items in the list in multi-thread mode with provided items consumer
|
TaskExecutionFuture<T> execute(java.util.List<I> items, java.util.function.Consumer<java.util.List<I>> taskConsumer)
items - the list of items to processtaskConsumer - instance of Consumer encapsulating the processing logicTaskExecutionFuture of the execution processTaskExecutionFuture<T> execute(java.util.List<I> items, java.util.function.Consumer<java.util.List<I>> taskConsumer, long predestroyTimeout)
items - the list of items to processtaskConsumer - instance of Consumer encapsulating the processing logicpredestroyTimeout - time in milliseconds to wait until forcing the thread join (to prevent eventual thread blocking)TaskExecutionFuture of the execution processCopyright © 2018 SAP SE. All Rights Reserved.