org.ldaptive.concurrent

Class AbstractOperationWorker<Q extends Request,S>

java.lang.Object

org.ldaptive.concurrent.AbstractOperationWorker<Q,S>

Type Parameters:

Q - type of ldap request

S - type of ldap response

All Implemented Interfaces:

OperationWorker<Q,S>

Direct Known Subclasses:

AddOperationWorker, BindOperationWorker, CompareOperationWorker, DeleteOperationWorker, ModifyDnOperationWorker, ModifyOperationWorker, SearchOperationWorker

public abstract class AbstractOperationWorker<Q extends Request,S>
extends java.lang.Object
implements OperationWorker<Q,S>

Base class for worker operations. If no ExecutorService is provided a cached thread pool is used by default.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	logger Logger for this class.
private Operation<Q,S>	operation operation to execute.
private java.util.concurrent.ExecutorService	service to submit operations to.

Constructor Summary

Constructors

Constructor and Description
AbstractOperationWorker(Operation<Q,S> op) Creates a new abstract operation worker.
AbstractOperationWorker(Operation<Q,S> op, java.util.concurrent.ExecutorService es) Creates a new abstract operation worker.

Method Summary

Modifier and Type	Method and Description
static <Q extends Request,S> java.util.concurrent.Callable<Response<S>>	createCallable(Operation<Q,S> operation, Q request) Returns a Callable that executes the supplied request with the supplied operation.
java.util.Collection<java.util.concurrent.Future<Response<S>>>	execute(Q... requests) Execute an ldap operation for each request on a separate thread.
java.util.concurrent.Future<Response<S>>	execute(Q request) Execute an ldap operation on a separate thread.
java.util.Collection<Response<S>>	executeToCompletion(Q... requests) Execute an ldap operation for each request on a separate thread and waits for all operations to complete.
protected void	finalize()
void	shutdown() Invokes ExecutorService.shutdown() on the underlying executor service.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.slf4j.Logger logger

Logger for this class.

operation

private final Operation<Q extends Request,S> operation

operation to execute.

service

private final java.util.concurrent.ExecutorService service

to submit operations to.

Constructor Detail

AbstractOperationWorker

public AbstractOperationWorker(Operation<Q,S> op)

Creates a new abstract operation worker.

Parameters:

op - operation

AbstractOperationWorker

public AbstractOperationWorker(Operation<Q,S> op,
                               java.util.concurrent.ExecutorService es)

Creates a new abstract operation worker.

Parameters:

op - operation

es - executor service

Method Detail

execute

public java.util.concurrent.Future<Response<S>> execute(Q request)

Execute an ldap operation on a separate thread.

Specified by:

execute in interface OperationWorker<Q extends Request,S>

Parameters:

request - containing the data required by this operation

Returns:

future response for this operation

execute

public java.util.Collection<java.util.concurrent.Future<Response<S>>> execute(Q... requests)

Execute an ldap operation for each request on a separate thread.

Specified by:

execute in interface OperationWorker<Q extends Request,S>

Parameters:

requests - containing the data required by this operation

Returns:

future responses for this operation

executeToCompletion

public java.util.Collection<Response<S>> executeToCompletion(Q... requests)

Execute an ldap operation for each request on a separate thread and waits for all operations to complete.

Specified by:

executeToCompletion in interface OperationWorker<Q extends Request,S>

Parameters:

requests - containing the data required by this operation

Returns:

responses for this operation

createCallable

public static <Q extends Request,S> java.util.concurrent.Callable<Response<S>> createCallable(Operation<Q,S> operation,
                                                                                              Q request)

Returns a Callable that executes the supplied request with the supplied operation.

Type Parameters:

Q - type of ldap request

S - type of ldap response

Parameters:

operation - to execute

request - to pass to the operation

Returns:

callable for the supplied operation and request

shutdown

public void shutdown()

Invokes ExecutorService.shutdown() on the underlying executor service.

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable