Package org.flag4j.concurrency

Class ThreadManager

java.lang.Object

org.flag4j.concurrency.ThreadManager

public final class ThreadManager
extends Object

This class contains the base thread pool for all concurrent operations and several methods for managing the pool.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ThreadManager.TriConsumer<T,U,V>

Field Summary

Fields

Modifier and Type	Field	Description
private static final ThreadFactory	daemonFactory	Simple thread factory for creating basic daemon threads.
private static int	parallelismLevel	The parallelism level for the thread manager.
private static final Logger	threadLogger	Simple logger for when a thread throws an exception during execution.
private static ThreadPoolExecutor	threadPool	Thread pool for managing threads executing concurrent operations.

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ThreadManager()

Method Summary

Modifier and Type	Method	Description
static void	concurrentBlockedOperation(int totalSize, int blockSize, TensorOperation blockedOperation)	Computes a specified blocked tensor operation concurrently by evenly dividing work amoung available threads (specified by Configurations.getNumThreads()).
static void	concurrentOperation(int totalSize, TensorOperation operation)	Computes a specified tensor operation concurrently by evenly dividing work amoung available threads (specified by Configurations.getNumThreads()).
static void	concurrentOperation(int totalTasks, ThreadManager.TriConsumer<Integer,Integer,Integer> task)	Executes a concurrent operation on a given range of indices.
static int	getParallelismLevel()	Gets the current parallelism level for the ThreadManager.
protected static void	setParallelismLevel(int parallelismLevel)	Sets the number of threads to use in the thread pool.

Methods inherited from class java.lang.Object

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

Field Details

daemonFactory

private static final ThreadFactory daemonFactory

Simple thread factory for creating basic daemon threads.

parallelismLevel

private static int parallelismLevel

The parallelism level for the thread manager. That is, the number of threads to be used in the thread pool when executing concurrent operations.

threadLogger

private static final Logger threadLogger

Simple logger for when a thread throws an exception during execution.

threadPool

private static ThreadPoolExecutor threadPool

Thread pool for managing threads executing concurrent operations.

Constructor Details

ThreadManager

private ThreadManager()

Method Details

setParallelismLevel

protected static void setParallelismLevel(int parallelismLevel)

Sets the number of threads to use in the thread pool.

Parameters:

parallelismLevel - Number of threads to use in the thread pool. If this is less than 1, the parallelism will simply be set to 1.

getParallelismLevel

public static int getParallelismLevel()

Gets the current parallelism level for the ThreadManager. That is, the number of threads used in the thread pool.

Returns:

The current parallelism level for the ThreadManager.

concurrentOperation

public static void concurrentOperation(int totalSize,
 TensorOperation operation)

Computes a specified tensor operation concurrently by evenly dividing work amoung available threads (specified by Configurations.getNumThreads()).

Parameters:

totalSize - Total size of the outer loop for the operation.

operation - Operation to be computed.

concurrentBlockedOperation

public static void concurrentBlockedOperation(int totalSize,
 int blockSize,
 TensorOperation blockedOperation)

Computes a specified blocked tensor operation concurrently by evenly dividing work amoung available threads (specified by Configurations.getNumThreads()).

Parameters:

totalSize - Total size of the outer loop for the operation.

blockSize - Size of the block used in the blocekdOperation.

blockedOperation - Operation to be computed.

concurrentOperation

public static void concurrentOperation(int totalTasks,
 ThreadManager.TriConsumer<Integer,Integer,Integer> task)

Executes a concurrent operation on a given range of indices. The operation is split across multiple threads, each handling a subset of the range.

Parameters:

totalTasks - The total number of tasks (e.g., rows in a matrix) to be processed.

task - A lambda expression or function that takes three arguments: start index, end index, and thread ID. This function represents the work to be done by each thread for its assigned range.