com.fr.third.jgroups.blocks.executor

类 ExecutionCompletionService<V>

java.lang.Object

com.fr.third.jgroups.blocks.executor.ExecutionCompletionService<V>

所有已实现的接口:

java.util.concurrent.CompletionService<V>

public class ExecutionCompletionService<V>
extends java.lang.Object
implements java.util.concurrent.CompletionService<V>

A CompletionService that uses a supplied ExecutionService 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.

This class must be used instead of a ExecutorCompletionService provided from java.util.concurrent package. The ExecutorCompletionService may not be used since it requires the use of a non serializable RunnableFuture object. Since a ExecutionService may only be used with serializable request objects, this class must be used instead.

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	ExecutionCompletionService.QueueingListener

字段概要

字段

限定符和类型	字段和说明
protected java.util.concurrent.BlockingQueue<NotifyingFuture<V>>	completionQueue
protected ExecutionService	executor
protected ExecutionCompletionService.QueueingListener	listener

构造器概要

构造器

限定符	构造器和说明
	ExecutionCompletionService(ExecutionService executor) Creates an ExecutorCompletionService using the supplied executor for base task execution and a LinkedBlockingQueue as a completion queue.
	ExecutionCompletionService(ExecutionService executor, java.util.concurrent.BlockingQueue<NotifyingFuture<V>> completionQueue) Creates an ExecutorCompletionService using the supplied executor for base task execution and the supplied queue as its completion queue.
protected	ExecutionCompletionService(ExecutionService executor, java.util.concurrent.BlockingQueue<NotifyingFuture<V>> completionQueue, ExecutionCompletionService.QueueingListener listener) This constructor is here if someone wants to override this class and provide their own QueueingListener to possibly listen in on futures being finished

方法概要

方法

限定符和类型	方法和说明
NotifyingFuture<V>	poll() This future may safely be used as a NotifyingFuture if desired.
NotifyingFuture<V>	poll(long timeout, java.util.concurrent.TimeUnit unit) This future may safely be used as a NotifyingFuture if desired.
java.util.concurrent.Future<V>	submit(java.util.concurrent.Callable<V> task) This future object may not be used as a NotifyingFuture.
java.util.concurrent.Future<V>	submit(java.lang.Runnable task, V result) This future object may not be used as a NotifyingFuture.
NotifyingFuture<V>	take() This future may safely be used as a NotifyingFuture if desired.

从类继承的方法 java.lang.Object

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

字段详细资料

executor

protected final ExecutionService executor

completionQueue

protected final java.util.concurrent.BlockingQueue<NotifyingFuture<V>> completionQueue

listener

protected final ExecutionCompletionService.QueueingListener listener

构造器详细资料

ExecutionCompletionService

public ExecutionCompletionService(ExecutionService executor)

Creates an ExecutorCompletionService using the supplied executor for base task execution and a LinkedBlockingQueue as a completion queue.

参数:

executor - the executor to use

抛出:

java.lang.NullPointerException - if executor is null

ExecutionCompletionService

public ExecutionCompletionService(ExecutionService executor,
                          java.util.concurrent.BlockingQueue<NotifyingFuture<V>> completionQueue)

Creates an ExecutorCompletionService using the supplied executor for base task execution and the supplied queue as its completion queue.

参数:

executor - the executor to use

completionQueue - the queue to use as the completion queue normally one dedicated for use by this service

抛出:

java.lang.NullPointerException - if executor is null

ExecutionCompletionService

protected ExecutionCompletionService(ExecutionService executor,
                          java.util.concurrent.BlockingQueue<NotifyingFuture<V>> completionQueue,
                          ExecutionCompletionService.QueueingListener listener)

This constructor is here if someone wants to override this class and provide their own QueueingListener to possibly listen in on futures being finished

参数:

executor - the executor to use

completionQueue - the queue to use as the completion queue normally one dedicated for use by this service

listener - the listener to notify. To work properly this listner should at minimum call the super.futureDone or else this completion service may not work correctly.

抛出:

java.lang.NullPointerException - if executor is null

方法详细资料

submit

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

This future object may not be used as a NotifyingFuture. That is because internally this class sets the listener to provide ability to add to the queue.

指定者:

submit 在接口中 java.util.concurrent.CompletionService<V>

submit

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

This future object may not be used as a NotifyingFuture. That is because internally this class sets the listener to provide ability to add to the queue.

指定者:

submit 在接口中 java.util.concurrent.CompletionService<V>

take

public NotifyingFuture<V> take()
                        throws java.lang.InterruptedException

This future may safely be used as a NotifyingFuture if desired. This is because if it tries to set a listener it will be called immediately since the task has already been completed.

指定者:

take 在接口中 java.util.concurrent.CompletionService<V>

抛出:

java.lang.InterruptedException

poll

public NotifyingFuture<V> poll()

This future may safely be used as a NotifyingFuture if desired. This is because if it tries to set a listener it will be called immediately since the task has already been completed.

指定者:

poll 在接口中 java.util.concurrent.CompletionService<V>

poll

public NotifyingFuture<V> poll(long timeout,
                      java.util.concurrent.TimeUnit unit)
                        throws java.lang.InterruptedException

This future may safely be used as a NotifyingFuture if desired. This is because if it tries to set a listener it will be called immediately since the task has already been completed.

指定者:

poll 在接口中 java.util.concurrent.CompletionService<V>

抛出:

java.lang.InterruptedException