com.datumbox.framework.common.concurrency

Class ThreadMethods

java.lang.Object

com.datumbox.framework.common.concurrency.ThreadMethods

public class ThreadMethods
extends java.lang.Object

This class contains a number of helper methods for Java 8 Threads.

Constructor Summary

Constructors

Constructor and Description
ThreadMethods()

Method Summary

Modifier and Type	Method and Description
static <T> T	forkJoinExecution(java.util.concurrent.Callable<T> callable, ConcurrencyConfiguration concurrencyConfiguration, boolean parallelStream) Alternative to parallelStreams() which executes a callable in a separate pool.
static void	forkJoinExecution(java.lang.Runnable runnable, ConcurrencyConfiguration concurrencyConfiguration, boolean parallelStream) Alternative to parallelStreams() which executes a runnable in a separate pool.
static <T> void	throttledExecution(java.util.stream.Stream<T> stream, java.util.function.Consumer<T> consumer, ConcurrencyConfiguration concurrencyConfiguration) Takes the items of the stream in a throttled way and provides them to the consumer.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadMethods

public ThreadMethods()

Method Detail

throttledExecution

public static <T> void throttledExecution(java.util.stream.Stream<T> stream,
                                          java.util.function.Consumer<T> consumer,
                                          ConcurrencyConfiguration concurrencyConfiguration)

Takes the items of the stream in a throttled way and provides them to the consumer. It uses as many threads as the available processors and it does not start more tasks than 2 times the previous number.

Type Parameters:

T -

Parameters:

stream -

consumer -

concurrencyConfiguration -

forkJoinExecution

public static <T> T forkJoinExecution(java.util.concurrent.Callable<T> callable,
                                      ConcurrencyConfiguration concurrencyConfiguration,
                                      boolean parallelStream)

Alternative to parallelStreams() which executes a callable in a separate pool.

Type Parameters:

T -

Parameters:

callable -

concurrencyConfiguration -

parallelStream -

Returns:

forkJoinExecution

public static void forkJoinExecution(java.lang.Runnable runnable,
                                     ConcurrencyConfiguration concurrencyConfiguration,
                                     boolean parallelStream)

Alternative to parallelStreams() which executes a runnable in a separate pool.

Parameters:

runnable -

concurrencyConfiguration -

parallelStream -