Package org.redisson.executor

Class RedissonCompletionService<V>

org.redisson.executor.RedissonCompletionService<V>

Type Parameters:

V - value type

All Implemented Interfaces:

<V>

public class RedissonCompletionService<V>
extends 
implements <V>

A that uses a supplied to execute tasks. This class arranges that submitted tasks are, upon completion, placed on a queue accessible using take. The class is lightweight enough to be suitable for transient use when processing groups of tasks.

Author:

Nikita Koksharov

Field Summary

Fields

Modifier and Type	Field	Description
protected <RFuture<V>>	completionQueue
protected RScheduledExecutorService	executorService

Constructor Summary

Constructors

Constructor	Description
RedissonCompletionService(RScheduledExecutorService executorService)
RedissonCompletionService(RScheduledExecutorService executorService, <RFuture<V>> completionQueue)

Method Summary

Modifier and Type	Method	Description
<V>	poll()
<V>	poll(long timeout, unit)
<V>	task, V result)
<V>	<V> task)
<V>	take()

Methods inherited from class java.lang.

, , , , , , , , , ,

Field Detail

executorService

protected final RScheduledExecutorService executorService

completionQueue

protected final <RFuture<V>> completionQueue

Constructor Detail

RedissonCompletionService

public RedissonCompletionService(RScheduledExecutorService executorService)

RedissonCompletionService

public RedissonCompletionService(RScheduledExecutorService executorService,
                                 <RFuture<V>> completionQueue)

Method Detail

submit

public <<V> task)

Specified by:

in interface <V>

submit

public < task,
                        V result)

Specified by:

in interface <V>

take

public <V> take()
               throws 

Specified by:

in interface <V>

Throws:

poll

public <V> poll()

Specified by:

in interface <V>

poll

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

Specified by:

in interface <V>

Throws: