com.rpl.rama.integration

Class ManagedResource<T>

java.lang.Object

com.rpl.rama.integration.ManagedResource<T>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

TaskThreadManagedResource, WorkerManagedResource

public abstract class ManagedResource<T>
extends java.lang.Object
implements java.io.Closeable

Constructor Summary

Constructors

Constructor and Description
ManagedResource(java.lang.String resourceId, TaskGlobalContext taskGlobalContext, java.util.concurrent.Callable<T> resourceConstructor)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the resource if it's an instance of java.io.Closeable.
T	getResource() Constructs the resource using the provided constructor if it doesn't yet exist in the resource map
protected abstract java.util.List	idTuple(TaskGlobalContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

ManagedResource

public ManagedResource(java.lang.String resourceId,
                       TaskGlobalContext taskGlobalContext,
                       java.util.concurrent.Callable<T> resourceConstructor)

Parameters:

resourceId - - a unique ID for this resource

taskGlobalContext - - the current TaskGlobalContext

resourceConstructor - - a function returning a new instance of the resource

Method Detail

idTuple

protected abstract java.util.List idTuple(TaskGlobalContext context)

getResource

public T getResource()

Constructs the resource using the provided constructor if it doesn't yet exist in the resource map

Returns:

the resource constructed

close

public void close()
           throws java.io.IOException

Closes the resource if it's an instance of java.io.Closeable. The resource will be closed only one time if shared across multiple task global instances. Will remove the resource from the map of resources

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException