Package csw.database.javadsl
Class AsyncHelper$
- java.lang.Object
-
- csw.database.javadsl.AsyncHelper$
-
public class AsyncHelper$ extends java.lang.Object
A java helper to schedule and execute blocking operations on a dedicated thread pool. This mechanism will prevent any blocking operation to be scheduled on a thread pool designated for async operations.
-
-
Field Summary
Fields Modifier and Type Field Description static AsyncHelper$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description AsyncHelper$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> java.util.concurrent.CompletableFuture<T>
managedBlock(java.util.function.Supplier<T> supplier)
The method wraps ForkJoinPool#managedBlock() and executes the provided supplier in a dedicated thread pool for blocking operations
-
-
-
Field Detail
-
MODULE$
public static final AsyncHelper$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
managedBlock
public <T> java.util.concurrent.CompletableFuture<T> managedBlock(java.util.function.Supplier<T> supplier)
The method wraps ForkJoinPool#managedBlock() and executes the provided supplier in a dedicated thread pool for blocking operations- Parameters:
supplier
- to be scheduled on a thread pool for blocking operations- Returns:
- a CompletableFuture that waits to complete till the supplier is ready to be executedx in the thread pool and produces the result of type T
-
-