Package org.jppf.client.concurrent

Class JPPFCompletionService<V>

java.lang.Object

org.jppf.client.concurrent.JPPFCompletionService<V>

Type Parameters:

V - the type of results returned by the submitted tasks.

All Implemented Interfaces:

CompletionService<V>

public class JPPFCompletionService<V>
extends Object
implements CompletionService<V>

A CompletionService which works specifically with JPPFExecutorServices.

Author:

Laurent Cohen

Constructor Summary

Constructors

Constructor	Description
JPPFCompletionService(JPPFExecutorService executor)	Initialize this completion service with the specified executor.

Method Summary

Modifier and Type	Method	Description
Future<V>	poll()
Future<V>	poll(long timeout, TimeUnit unit)
Future<V>	submit(Runnable task, V result)
Future<V>	submit(Callable<V> task)
Future<V>	take()

Methods inherited from class java.lang.Object

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

Constructor Details

JPPFCompletionService

public JPPFCompletionService(JPPFExecutorService executor)

Initialize this completion service with the specified executor.

Parameters:

executor - the executor to which tasks are submitted.

Method Details

submit

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

Specified by:

submit in interface CompletionService<V>

submit

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

Specified by:

submit in interface CompletionService<V>

take

public Future<V> take()
               throws InterruptedException

Specified by:

take in interface CompletionService<V>

Throws:

InterruptedException

poll

public Future<V> poll()

Specified by:

poll in interface CompletionService<V>

poll

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

Specified by:

poll in interface CompletionService<V>

Throws:

InterruptedException