de.ipcon.tools.concurrent

Class ConcurrencyTools

java.lang.Object

de.ipcon.tools.concurrent.ConcurrencyTools

public class ConcurrencyTools
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static void	checkThreadInterrupted(java.lang.String msg, org.apache.log4j.Logger logger) Convenience method that will check if the current thread was interrupted and if that is the case log the given message to the given logger (Level WARN) and throw an InterruptedException.
static java.lang.Object	evaluateFuture(java.util.concurrent.Future future, org.apache.log4j.Logger logger, boolean doThrow, java.lang.String text) Blocks until all passed Futures have completed.
static java.lang.Object	evaluateFuture(java.util.concurrent.Future future, org.apache.log4j.Logger logger, boolean doThrow, java.lang.String progressStart, java.lang.String progress, java.lang.String progressFinish) Blocks until the passed Future has completed.
static java.util.List<java.lang.Object>	evaluateFutures(java.util.List<java.util.concurrent.Future> futures, org.apache.log4j.Logger logger, boolean doThrow, java.lang.String text) Blocks until all passed Futures have completed.
static java.util.List<java.lang.Object>	evaluateFutures(java.util.List<java.util.concurrent.Future> futures, org.apache.log4j.Logger logger, boolean doThrow, java.lang.String progressStart, java.lang.String progress, java.lang.String progressFinish) Blocks until all passed Futures have completed.
static int	getReasonableParallelity() Returns the number of parallel tasks the system can handle without overloading, based on the number of available processors and predefined rules to reserve CPUs for system tasks.

Methods inherited from class java.lang.Object

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

Method Detail

getReasonableParallelity

public static final int getReasonableParallelity()

Returns the number of parallel tasks the system can handle without overloading, based on the number of available processors and predefined rules to reserve CPUs for system tasks.

Note: This is an idealized number assuming minimal other parallel work on the system.

Rules for parallel task calculation:

• More than 16 CPUs: reserves 6 CPUs.
• 7-16 CPUs: reserves 3 CPUs.
• 2-6 CPUs: reserves 1 CPU.
• 1 CPU: ensures at least 2 parallel tasks (for containerized environments).

Returns:

The reasonable number of parallel tasks the system can handle.

evaluateFuture

public static final java.lang.Object evaluateFuture(java.util.concurrent.Future future,
                                                    org.apache.log4j.Logger logger,
                                                    boolean doThrow,
                                                    java.lang.String progressStart,
                                                    java.lang.String progress,
                                                    java.lang.String progressFinish)

Blocks until the passed Future has completed.

Returns:

the result of the evaluation of the future.

evaluateFuture

public static final java.lang.Object evaluateFuture(java.util.concurrent.Future future,
                                                    org.apache.log4j.Logger logger,
                                                    boolean doThrow,
                                                    java.lang.String text)

Blocks until all passed Futures have completed.

Returns:

a List with all results.

evaluateFutures

public static final java.util.List<java.lang.Object> evaluateFutures(java.util.List<java.util.concurrent.Future> futures,
                                                                     org.apache.log4j.Logger logger,
                                                                     boolean doThrow,
                                                                     java.lang.String progressStart,
                                                                     java.lang.String progress,
                                                                     java.lang.String progressFinish)

Blocks until all passed Futures have completed.

Returns:

a List with all results.

evaluateFutures

public static final java.util.List<java.lang.Object> evaluateFutures(java.util.List<java.util.concurrent.Future> futures,
                                                                     org.apache.log4j.Logger logger,
                                                                     boolean doThrow,
                                                                     java.lang.String text)

Blocks until all passed Futures have completed.

Returns:

a List with all results.

checkThreadInterrupted

public static final void checkThreadInterrupted(java.lang.String msg,
                                                org.apache.log4j.Logger logger)
                                         throws java.lang.InterruptedException

Convenience method that will check if the current thread was interrupted and if that is the case log the given message to the given logger (Level WARN) and throw an InterruptedException.

Throws:

java.lang.InterruptedException