Package io.github.ascopes.protobufmavenplugin.utils

Class ConcurrentExecutor

java.lang.Object

io.github.ascopes.protobufmavenplugin.utils.ConcurrentExecutor

@Named
public final class ConcurrentExecutor
extends Object

Helper component that allows scheduling IO-bound tasks within a thread pool.

Since:

2.2.0

Author:

Ashley Scopes

Constructor Summary

Constructors

Constructor	Description
ConcurrentExecutor()

Method Summary

Modifier and Type	Method	Description
<R> Collector<FutureTask<R>,?,List<R>>	awaiting()	Return a reactive collector of all the results of a stream of scheduled tasks.
void	destroy()	Destroy the internal thread pool.
<R> FutureTask<R>	submit(Callable<R> task)

Methods inherited from class java.lang.Object

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

Constructor Details

ConcurrentExecutor

public ConcurrentExecutor()

Method Details

destroy

@PreDestroy
public void destroy()
             throws InterruptedException

Destroy the internal thread pool.

Throws:

InterruptedException - if destruction timed out or the thread was interrupted.

submit

public <R> FutureTask<R> submit(Callable<R> task)

awaiting

public <R> Collector<FutureTask<R>,?,List<R>> awaiting()

Return a reactive collector of all the results of a stream of scheduled tasks.

Type Parameters:

R - the task return type.

Returns:

the collector.

Throws:

MultipleFailuresException - if any of the results raised exceptions. All results are collected prior to this being raised.