com.alexkasko.unsafe.offheapstruct

Class LimitedInvoker

java.lang.Object

com.alexkasko.unsafe.offheapstruct.LimitedInvoker

 class LimitedInvoker
extends Object

Auxiliary class that limits the number of Executor threads those can be used simultaneously.

Author:

alexkasko Date: 11/14/13

Field Summary

Fields

Modifier and Type	Field and Description
private Executor	executor
private int	maxThreads

Constructor Summary

Constructors

Constructor and Description
LimitedInvoker(Executor executor, int maxThreads) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
private void	await(ExecutorCompletionService<Void> completer) Waits for Future to complete
(package private) void	invokeAll(Collection<? extends Runnable> tasks) Executes all the tasks simultaneously using no more than maxThreads threads from the executor

Methods inherited from class java.lang.Object

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

Field Detail

executor

private final Executor executor

maxThreads

private final int maxThreads

Constructor Detail

LimitedInvoker

LimitedInvoker(Executor executor,
              int maxThreads)

Constructor

Parameters:

executor - executor

maxThreads - maximum number of simultaneously used threads

Method Detail

invokeAll

void invokeAll(Collection<? extends Runnable> tasks)

Executes all the tasks simultaneously using no more than maxThreads threads from the executor

Parameters:

tasks - runnables to execute

await

private void await(ExecutorCompletionService<Void> completer)

Waits for Future to complete

Parameters:

completer - executor service