Package uk.ac.manchester.spinnaker.front_end

Class BasicExecutor

java.lang.Object

uk.ac.manchester.spinnaker.front_end.BasicExecutor

All Implemented Interfaces:

AutoCloseable

public class BasicExecutor
extends Object
implements AutoCloseable

A thread pool designed for simple task execution with combining of exceptions.

Author:

Donal Fellows

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	BasicExecutor.SimpleCallable	The type of task that this executor can run.
static final class	BasicExecutor.Tasks	Holds the future results of the submitted tasks.

Constructor Summary

Constructors

Constructor	Description
BasicExecutor(int parallelSize)	Create an instance of the pool.

Method Summary

Modifier and Type	Method	Description
void	close()
BasicExecutor.Tasks	submitTasks(Iterable<BasicExecutor.SimpleCallable> tasks)	Submit some tasks to the pool.
<T> BasicExecutor.Tasks	submitTasks(Collection<T> items, Function<T,BasicExecutor.SimpleCallable> taskMapper)	Submit some tasks to the pool.
<T> BasicExecutor.Tasks	submitTasks(Stream<T> items, Function<T,BasicExecutor.SimpleCallable> taskMapper)	Submit some tasks to the pool.
BasicExecutor.Tasks	submitTasks(Stream<BasicExecutor.SimpleCallable> tasks)	Submit some tasks to the pool.

Methods inherited from class java.lang.Object

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

Constructor Details

BasicExecutor

@MustBeClosed
public BasicExecutor(int parallelSize)

Create an instance of the pool.

Parameters:

parallelSize - The number of threads to use inside the pool.

Method Details

submitTasks

public BasicExecutor.Tasks submitTasks(Stream<BasicExecutor.SimpleCallable> tasks)

Submit some tasks to the pool.

Parameters:

tasks - The tasks to submit. Should not be a parallel stream.

Returns:

The future holding the results of the execution.

submitTasks

public <T> BasicExecutor.Tasks submitTasks(Stream<T> items,
 Function<T,BasicExecutor.SimpleCallable> taskMapper)

Submit some tasks to the pool.

Type Parameters:

T - The type of the items.

Parameters:

items - The items representing tasks to submit. Should not be a parallel stream.

taskMapper - How to convert the item to a task.

Returns:

The future holding the results of the execution.

submitTasks

public <T> BasicExecutor.Tasks submitTasks(Collection<T> items,
 Function<T,BasicExecutor.SimpleCallable> taskMapper)

Submit some tasks to the pool.

Type Parameters:

T - The type of the items.

Parameters:

items - The items representing tasks to submit.

taskMapper - How to convert the item to a task.

Returns:

The future holding the results of the execution.

submitTasks

public BasicExecutor.Tasks submitTasks(Iterable<BasicExecutor.SimpleCallable> tasks)

Submit some tasks to the pool.

Parameters:

tasks - The tasks to submit.

Returns:

The future holding the results of the execution.

close

public void close()
           throws InterruptedException

Specified by:

close in interface AutoCloseable

Throws:

InterruptedException