Package org.infinispan.executors

Class SemaphoreCompletionService<T>

java.lang.Object

org.infinispan.executors.SemaphoreCompletionService<T>

All Implemented Interfaces:

CompletionService<T>

public class SemaphoreCompletionService<T>
extends Object
implements CompletionService<T>

Executes tasks in the given executor, but never has more than maxConcurrentTasks tasks running at the same time.

Since:

7.2

Author:

Dan Berindei

Constructor Summary

Constructors

Constructor	Description
SemaphoreCompletionService(Executor executor, int maxConcurrentTasks)

Method Summary

Modifier and Type	Method	Description
Future<T>	backgroundTaskFinished(Callable<T> cleanupTask)	Signal that a task that called continueTaskInBackground() has finished and optionally execute another task on the just-freed thread.
void	cancelQueuedTasks()	When stopping, cancel any queued tasks.
void	continueTaskInBackground()	Called from a task to remove the permit that would otherwise be freed when the task finishes running When the asynchronous part of the task finishes, it must call backgroundTaskFinished(Callable) to make the permit available again.
List<? extends Future<T>>	drainCompletionQueue()
Future<T>	poll()
Future<T>	poll(long timeout, TimeUnit unit)
Future<T>	submit(Runnable task, T result)
Future<T>	submit(Callable<T> task)
Future<T>	take()

Methods inherited from class java.lang.Object

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

Constructor Details

SemaphoreCompletionService

public SemaphoreCompletionService(Executor executor,
 int maxConcurrentTasks)

Method Details

drainCompletionQueue

public List<? extends Future<T>> drainCompletionQueue()

cancelQueuedTasks

public void cancelQueuedTasks()

When stopping, cancel any queued tasks.

continueTaskInBackground

public void continueTaskInBackground()

Called from a task to remove the permit that would otherwise be freed when the task finishes running When the asynchronous part of the task finishes, it must call backgroundTaskFinished(Callable) to make the permit available again.

backgroundTaskFinished

public Future<T> backgroundTaskFinished(Callable<T> cleanupTask)

Signal that a task that called continueTaskInBackground() has finished and optionally execute another task on the just-freed thread.

submit

public Future<T> submit(Callable<T> task)

Specified by:

submit in interface CompletionService<T>

submit

public Future<T> submit(Runnable task,
 T result)

Specified by:

submit in interface CompletionService<T>

take

public Future<T> take()
               throws InterruptedException

Specified by:

take in interface CompletionService<T>

Throws:

InterruptedException

poll

public Future<T> poll()

Specified by:

poll in interface CompletionService<T>

poll

public Future<T> poll(long timeout,
 TimeUnit unit)
               throws InterruptedException

Specified by:

poll in interface CompletionService<T>

Throws:

InterruptedException