fi.techila.user

Class TechilaExecutorCompletionService<T,V>

java.lang.Object

fi.techila.user.TechilaExecutorCompletionService<T,V>

Type Parameters:

T -

V -

All Implemented Interfaces:

java.util.concurrent.CompletionService<V>

public class TechilaExecutorCompletionService<T,V>
extends java.lang.Object
implements java.util.concurrent.CompletionService<V>

TechilaExecutorCompletionService. Only submitting Callables is supported at this time. Also take is the only supported method for getting the results.

Constructor Summary

Constructors

Constructor and Description
TechilaExecutorCompletionService(TechilaExecutorService<T> tes)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.Future<V>	poll()
java.util.concurrent.Future<V>	poll(long timeout, java.util.concurrent.TimeUnit unit)
java.util.concurrent.Future<V>	submit(java.util.concurrent.Callable<V> task)
java.util.concurrent.Future<V>	submit(java.lang.Runnable task, V result)
TechilaFutureTask<V>	take()

Methods inherited from class java.lang.Object

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

Constructor Detail

TechilaExecutorCompletionService

public TechilaExecutorCompletionService(TechilaExecutorService<T> tes)

Method Detail

poll

public java.util.concurrent.Future<V> poll()

Specified by:

poll in interface java.util.concurrent.CompletionService<V>

poll

public java.util.concurrent.Future<V> poll(long timeout,
                                           java.util.concurrent.TimeUnit unit)

Specified by:

poll in interface java.util.concurrent.CompletionService<V>

submit

public java.util.concurrent.Future<V> submit(java.util.concurrent.Callable<V> task)

Specified by:

submit in interface java.util.concurrent.CompletionService<V>

submit

public java.util.concurrent.Future<V> submit(java.lang.Runnable task,
                                             V result)

Specified by:

submit in interface java.util.concurrent.CompletionService<V>

take

public TechilaFutureTask<V> take()

Specified by:

take in interface java.util.concurrent.CompletionService<V>