Class OperationHandleImpl<T extends java.lang.annotation.Annotation>
- java.lang.Object
-
- org.glassfish.hk2.extras.operation.internal.OperationHandleImpl<T>
-
- All Implemented Interfaces:
OperationHandle<T>
public class OperationHandleImpl<T extends java.lang.annotation.Annotation> extends java.lang.Object implements OperationHandle<T>
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.HashSet<java.lang.Long>
activeThreads
private OperationIdentifier<T>
identifier
private java.lang.Object
operationLock
private SingleOperationManager<T>
parent
private OperationState
state
private java.lang.Object
userData
-
Constructor Summary
Constructors Constructor Description OperationHandleImpl(SingleOperationManager<T> parent, OperationIdentifier<T> identifier, java.lang.Object operationLock, ServiceLocator locator)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private void
checkState()
void
closeOperation()
suspends this Operation on all threads where it is associated and closes the operation.boolean
equals(java.lang.Object o)
java.util.Set<java.lang.Long>
getActiveThreads()
Gets a set of threads upon which this Operation is activeOperationIdentifier<T>
getIdentifier()
Returns a unique identifier for this operationjava.lang.Object
getOperationData()
Gets arbitrary Operation data to be associated with this OperationOperationState
getState()
Gets the current state of this operationint
hashCode()
void
resume()
Resumes this operation on the current thread.void
resume(long threadId)
Resumes this operation on the given thread id.void
setOperationData(java.lang.Object data)
Sets arbitrary Operation data to be associated with this Operation(package private) void
shutdownByFiat()
operationLock must be heldvoid
suspend()
Suspends this operation on the current thread.void
suspend(long threadId)
Suspends this operation on the given thread id.java.lang.String
toString()
-
-
-
Field Detail
-
parent
private final SingleOperationManager<T extends java.lang.annotation.Annotation> parent
-
identifier
private final OperationIdentifier<T extends java.lang.annotation.Annotation> identifier
-
operationLock
private final java.lang.Object operationLock
-
state
private OperationState state
-
activeThreads
private final java.util.HashSet<java.lang.Long> activeThreads
-
userData
private java.lang.Object userData
-
-
Constructor Detail
-
OperationHandleImpl
OperationHandleImpl(SingleOperationManager<T> parent, OperationIdentifier<T> identifier, java.lang.Object operationLock, ServiceLocator locator)
-
-
Method Detail
-
getIdentifier
public OperationIdentifier<T> getIdentifier()
Description copied from interface:OperationHandle
Returns a unique identifier for this operation- Specified by:
getIdentifier
in interfaceOperationHandle<T extends java.lang.annotation.Annotation>
- Returns:
- A non-null unique identifier for this operation
-
getState
public OperationState getState()
Description copied from interface:OperationHandle
Gets the current state of this operation- Specified by:
getState
in interfaceOperationHandle<T extends java.lang.annotation.Annotation>
- Returns:
- The current state of this operation
-
shutdownByFiat
void shutdownByFiat()
operationLock must be held
-
checkState
private void checkState()
-
getActiveThreads
public java.util.Set<java.lang.Long> getActiveThreads()
Description copied from interface:OperationHandle
Gets a set of threads upon which this Operation is active- Specified by:
getActiveThreads
in interfaceOperationHandle<T extends java.lang.annotation.Annotation>
- Returns:
- The set of threads upon which this Operation is active
-
suspend
public void suspend(long threadId)
Description copied from interface:OperationHandle
Suspends this operation on the given thread id. If this Operation is not associated with the given threadId this method does nothing- Specified by:
suspend
in interfaceOperationHandle<T extends java.lang.annotation.Annotation>
- Parameters:
threadId
- The thread on which to suspend this operation
-
suspend
public void suspend()
Description copied from interface:OperationHandle
Suspends this operation on the current thread. If this Operation is not associated with the current threadId this method does nothing- Specified by:
suspend
in interfaceOperationHandle<T extends java.lang.annotation.Annotation>
-
resume
public void resume(long threadId) throws java.lang.IllegalStateException
Description copied from interface:OperationHandle
Resumes this operation on the given thread id. If this Operation is already associated with the given threadId this method does nothing- Specified by:
resume
in interfaceOperationHandle<T extends java.lang.annotation.Annotation>
- Parameters:
threadId
- The thread on which to resume this operation- Throws:
java.lang.IllegalStateException
- if the Operation is closed or if the given thread is associated with a different Operation of the same type
-
resume
public void resume() throws java.lang.IllegalStateException
Description copied from interface:OperationHandle
Resumes this operation on the current thread. If this Operation is already associated with the current thread this method does nothing- Specified by:
resume
in interfaceOperationHandle<T extends java.lang.annotation.Annotation>
- Throws:
java.lang.IllegalStateException
- if the Operation is closed or if the current thread is associated with a different Operation of the same type
-
closeOperation
public void closeOperation()
Description copied from interface:OperationHandle
suspends this Operation on all threads where it is associated and closes the operation. All resume calls on this handle after this is called will throw IllegalStateException. If this handle is already closed this method does nothing- Specified by:
closeOperation
in interfaceOperationHandle<T extends java.lang.annotation.Annotation>
-
getOperationData
public java.lang.Object getOperationData()
Description copied from interface:OperationHandle
Gets arbitrary Operation data to be associated with this Operation- Specified by:
getOperationData
in interfaceOperationHandle<T extends java.lang.annotation.Annotation>
- Returns:
- Arbitrary (possibly null) data that is associated with this Operation
-
setOperationData
public void setOperationData(java.lang.Object data)
Description copied from interface:OperationHandle
Sets arbitrary Operation data to be associated with this Operation- Specified by:
setOperationData
in interfaceOperationHandle<T extends java.lang.annotation.Annotation>
- Parameters:
data
- (possibly null) data that is associated with this Operation
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-