com.ibasco.agql.core.util

Class Concurrency

java.lang.Object

com.ibasco.agql.core.util.Concurrency

@ApiStatus.Internal
public final class Concurrency
extends Object

Concurrency class.

Author:

Rafael Luis Ibasco

Constructor Summary

Constructors

Constructor and Description
Concurrency()

Method Summary

Modifier and Type	Method and Description
static <A,B> B	combine(A a, B b) combine.
static <V> CompletableFuture<V>	failedFuture(Throwable error) failedFuture.
static <V> CompletableFuture<V>	failedFuture(Throwable error, Executor executor) failedFuture.
static int	getCorePoolSize(Executor executor) Retrieve the core pool size of an executor (if available)
static boolean	shutdown(ExecutorService executorService) Shutdown an ExecutorService the right way.
static boolean	shutdown(ExecutorService executorService, int timeout, TimeUnit timeUnit) Shutdown an ExecutorService the right way.
static void	sleepUninterrupted(int milliseconds) Sleep without interruption
static <V> CompletionStage<V>	wrap(CompletableFuture<V> future) wrap.

Methods inherited from class java.lang.Object

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

Constructor Detail

Concurrency

public Concurrency()

Method Detail

wrap

public static <V> CompletionStage<V> wrap(CompletableFuture<V> future)

wrap.

Type Parameters:

V - a V class

Parameters:

future - a CompletableFuture object

Returns:

a CompletionStage object

combine

public static <A,B> B combine(A a,
                              B b)

combine.

Type Parameters:

A - a A class

B - a B class

Parameters:

a - a A object

b - a B object

Returns:

a B object

failedFuture

public static <V> CompletableFuture<V> failedFuture(Throwable error)

failedFuture.

Type Parameters:

V - a V class

Parameters:

error - a Throwable object

Returns:

a CompletableFuture object

failedFuture

public static <V> CompletableFuture<V> failedFuture(Throwable error,
                                                    Executor executor)

failedFuture.

Type Parameters:

V - a V class

Parameters:

error - a Throwable object

executor - a Executor object

Returns:

a CompletableFuture object

shutdown

public static boolean shutdown(ExecutorService executorService)

Shutdown an ExecutorService the right way. This uses the default timeout parameters.

Parameters:

executorService - The ExecutorService to shutdown

Returns:

true if the ExecutorService shutdown successfully false if executor service is null, timeout has expired or shutdown was interrupted

shutdown

public static boolean shutdown(ExecutorService executorService,
                               int timeout,
                               TimeUnit timeUnit)

Shutdown an ExecutorService the right way. This method blocks if there are still tasks running in the executor.

Parameters:

executorService - The ExecutorService to shutdown

timeout - The timeout value to wait for a successful termination

timeUnit - The TimeUnit of the timeout value

Returns:

true if the ExecutorService shutdown successfully false if executor service is null, timeout has expired or shutdown was interrupted

sleepUninterrupted

public static void sleepUninterrupted(int milliseconds)

Sleep without interruption

Parameters:

milliseconds - The number of milliseconds to sleep

getCorePoolSize

public static int getCorePoolSize(Executor executor)

Retrieve the core pool size of an executor (if available)

Parameters:

executor - The Executor to check

Returns:

An integer representing the number of threads available for the Executor