com.client.core.base.service.concurrency.impl

Class StandardConcurrencyService

java.lang.Object

com.client.core.base.service.concurrency.impl.StandardConcurrencyService

All Implemented Interfaces:

ConcurrencyService

@Service
public class StandardConcurrencyService
extends java.lang.Object
implements ConcurrencyService

Service to handle calling threads asynchronously as well as synchronously. Provided methods to call a single thread asynchronously or a collection of threads either asynchronously or synchonously. Supports both Runnable and Callable.

Implementation uses Executors and ExecutorService

Constructor Summary

Constructors

Constructor and Description
StandardConcurrencyService()

Method Summary

Modifier and Type	Method and Description
<R extends java.lang.Runnable> void	spinOneThreadAndDoNotWaitForCompletion(R task) Handles the passed in Runnable concurrently.
<T,C extends java.util.concurrent.Callable<T>> void	spinOneThreadAndDoNotWaitForResult(C task) Handles the passed in taskList concurrently.
<R extends java.lang.Runnable> void	spinThreadsAndDoNotWaitForCompletion(java.util.List<R> taskList) Handles the passed in List<Runnable> concurrently.
<T,C extends java.util.concurrent.Callable<T>> void	spinThreadsAndDoNotWaitForResult(java.util.List<C> taskList) Handles the passed in taskList concurrently.
<R extends java.lang.Runnable> void	spinThreadsAndWaitForCompletion(java.util.List<R> taskList) Handles the passed in List<Runnable> concurrently.
<T,C extends java.util.concurrent.Callable<T>> java.util.List<T>	spinThreadsAndWaitForResult(java.util.List<C> taskList) Handles the passed in taskList concurrently, and returns the result.

Methods inherited from class java.lang.Object

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

Constructor Detail

StandardConcurrencyService

public StandardConcurrencyService()

Method Detail

spinThreadsAndWaitForResult

public <T,C extends java.util.concurrent.Callable<T>> java.util.List<T> spinThreadsAndWaitForResult(java.util.List<C> taskList)

Handles the passed in taskList concurrently, and returns the result.

Specified by:

spinThreadsAndWaitForResult in interface ConcurrencyService

Type Parameters:

T - result of Callable being passed

C - type of Callable being called

Parameters:

taskList - list of tasks to run

Returns:

result of running taskList

spinThreadsAndDoNotWaitForResult

public <T,C extends java.util.concurrent.Callable<T>> void spinThreadsAndDoNotWaitForResult(java.util.List<C> taskList)

Handles the passed in taskList concurrently. There is not guarantee this method will execute before subsequent client code. This method is appropriate when client code is not depending on the result of the passed in List> to function.

Specified by:

spinThreadsAndDoNotWaitForResult in interface ConcurrencyService

Type Parameters:

T - result of Callable being passed

C - type of Callable being called

Parameters:

taskList - list of tasks to run

spinOneThreadAndDoNotWaitForResult

public <T,C extends java.util.concurrent.Callable<T>> void spinOneThreadAndDoNotWaitForResult(C task)

Handles the passed in taskList concurrently. There is not guarantee this method will execute before subsequent client code. This method is appropriate when client code is not depending on the result of the passed in Callable.

Specified by:

spinOneThreadAndDoNotWaitForResult in interface ConcurrencyService

Type Parameters:

T - result of Callable being passed

C - type of Callable being called

Parameters:

task - the task to run

spinOneThreadAndDoNotWaitForCompletion

public <R extends java.lang.Runnable> void spinOneThreadAndDoNotWaitForCompletion(R task)

Handles the passed in Runnable concurrently. There is no guarantee this method will execute before subsequent client code. This method is appropriate when client code is not depending on the passed in Runnable being completed.

Specified by:

spinOneThreadAndDoNotWaitForCompletion in interface ConcurrencyService

Type Parameters:

R - type of Runnable being called

Parameters:

task - the task to run

spinThreadsAndWaitForCompletion

public <R extends java.lang.Runnable> void spinThreadsAndWaitForCompletion(java.util.List<R> taskList)

Handles the passed in List<Runnable> concurrently. There is no guarantee this method will execute before subsequent client code. This method is appropriate when client code is depending on the passed in Runnables being completed.

Specified by:

spinThreadsAndWaitForCompletion in interface ConcurrencyService

Type Parameters:

R - type of Runnable being called

Parameters:

taskList - the list of tasks to run

spinThreadsAndDoNotWaitForCompletion

public <R extends java.lang.Runnable> void spinThreadsAndDoNotWaitForCompletion(java.util.List<R> taskList)

Handles the passed in List<Runnable> concurrently. There is no guarantee this method will execute before subsequent client code. This method is appropriate when client code is not depending on the passed in Runnables being completed.

Specified by:

spinThreadsAndDoNotWaitForCompletion in interface ConcurrencyService

Type Parameters:

R - type of Runnable being called

Parameters:

taskList - the list of tasks to run