Package com.oracle.coherence.concurrent.executor

Class ClusteredExecutorInfo

java.lang.Object

com.tangosol.io.AbstractEvolvable

com.oracle.coherence.concurrent.executor.ClusteredExecutorInfo

All Implemented Interfaces:

com.oracle.coherence.concurrent.executor.internal.ClusterMemberAware, com.oracle.coherence.concurrent.executor.internal.Leased, com.oracle.coherence.concurrent.executor.internal.LiveObject, TaskExecutorService.ExecutorInfo, Evolvable, ExternalizableLite, EvolvablePortableObject, PortableObject, Serializable

public class ClusteredExecutorInfo
extends AbstractEvolvable
implements TaskExecutorService.ExecutorInfo, com.oracle.coherence.concurrent.executor.internal.LiveObject, com.oracle.coherence.concurrent.executor.internal.Leased, com.oracle.coherence.concurrent.executor.internal.ClusterMemberAware, EvolvablePortableObject

A Coherence-based implementation of a TaskExecutorService.ExecutorInfo.

Since:

21.12

Author:

bo

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	ClusteredExecutorInfo.CacheAwareContinuation	A base ComposableContinuation that allows subclasses access to the underlying caches that drive the executor service.
static class	ClusteredExecutorInfo.ClosingContinuation	A ComposableContinuation to close a ClusteredExecutorInfo, including cleaning up assigned Tasks.
static class	ClusteredExecutorInfo.ClosingGracefullyContinuation	A ComposableContinuation to gracefully close a ClusteredExecutorInfo, allowing already assigned Tasks to complete.
static class	ClusteredExecutorInfo.JoiningContinuation	A ComposableContinuation to commence orchestrating a new Executor with existing Tasks.
static class	ClusteredExecutorInfo.RemoveContinuation	A ComposableContinuation to remove a ClusteredExecutorInfo.
static class	ClusteredExecutorInfo.SetStateProcessor	An InvocableMap.EntryProcessor to compare and set the state of a ClusteredExecutorInfo, returning the previous state.
static class	ClusteredExecutorInfo.TouchProcessor	An InvocableMap.EntryProcessor to update the last update timestamp of a ClusteredExecutorInfo.
static class	ClusteredExecutorInfo.TouchRunnable	A Runnable to asynchronously touch.
static class	ClusteredExecutorInfo.UpdateInfoProcessor	An InvocableMap.EntryProcessor to update the state of an TaskExecutorService.ExecutorInfo.
static class	ClusteredExecutorInfo.UpdateInfoRunnable	A Runnable to asynchronously update the state of ClusteredExecutorInfo using the information based on the current Runtime.

Nested classes/interfaces inherited from interface com.oracle.coherence.concurrent.executor.TaskExecutorService.ExecutorInfo

TaskExecutorService.ExecutorInfo.State

Field Summary

Fields

Modifier and Type	Field	Description
static long	LEASE_DURATION_MS	The duration of a lease for Executors.
protected long	m_cCompleted	The completed tasks count.
protected long	m_cFreeMemory	The free memory as reported by Runtime.freeMemory().
protected long	m_cInProgress	The tasks that are in progress count.
protected long	m_cMaxMemory	The maximum memory as reported by Runtime.maxMemory().
protected long	m_cRejected	The rejected tasks count.
protected long	m_cTotalMemory	The total memory as reported by Runtime.totalMemory().
protected long	m_ldtJoined	The cluster time when the TaskExecutorService.ExecutorInfo joined the service.
protected long	m_ldtUpdate	The cluster time when the TaskExecutorService.ExecutorInfo was last updated.
protected OptionsByType<TaskExecutorService.Registration.Option>	m_optionsByType	The TaskExecutorService.Registration.Options for the Executor.
protected String	m_sIdentity	The identity of the TaskExecutorService.Registration.
protected TaskExecutorService.ExecutorInfo.State	m_state	The TaskExecutorService.ExecutorInfo.State of the Executor.
protected static int	VERSION	PortableObject version.

Constructor Summary

Constructors

Constructor	Description
ClusteredExecutorInfo()	Constructs a ClusteredExecutorInfo (for serialization support).
ClusteredExecutorInfo(String sIdentity, long ldtUpdate, long cMaxMemory, long totalMemory, long freeMemory, OptionsByType<TaskExecutorService.Registration.Option> optionsByType)	Constructs a ClusteredExecutorInfo with the specified parameters.

Method Summary

Modifier and Type	Method	Description
String	getDescription()	Return the description of the ClusteredExecutorInfo.
String	getExecutorName()	Return the logical name of this ClusteredExecutorInfo.
long	getFreeMemory()	The last reported free memory by Runtime.freeMemory() available to the ExecutorService.
String	getId()	Obtains the unique identity for the ExecutorService.
int	getImplVersion()	Determine the serialization version supported by the implementing class.
long	getJoinTime()	Returns the time since the epoch when the associated executor joined the service.
long	getLastUpdateTime()	Obtains the time since the epoch when the TaskExecutorService.ExecutorInfo was last updated.
long	getLeaseExpiryTime()	Obtains the time the lease will expiry (in milliseconds since the epoc).
long	getMaxMemory()	The last reported maximum memory by Runtime.maxMemory() available to the ExecutorService.
<T extends TaskExecutorService.Registration.Option> T	getOption(Class<T> clzOfOption, T defaultIfNotFound)	Obtains the TaskExecutorService.Registration.Option of the specified class when the ExecutorService was registered, or the default value if not found.
TaskExecutorService.ExecutorInfo.State	getState()	Obtains the current TaskExecutorService.ExecutorInfo.State of the Executor.
long	getTasksCompletedCount()	Return the number of completed tasks.
long	getTasksInProgressCount()	Return the number of tasks currently in progress.
long	getTasksRejectedCount()	Return the number rejected tasks.
long	getTotalMemory()	The last reported total memory by Runtime.totalMemory() available to the ExecutorService.
UID	getUid()	The UID of the Member for which this object wishes to receive membership events.
ComposableContinuation	onDeleted(CacheService service, InvocableMap.Entry entry, com.oracle.coherence.concurrent.executor.internal.Cause cause)	The LiveObject was deleted.
ComposableContinuation	onInserted(CacheService service, InvocableMap.Entry entry, com.oracle.coherence.concurrent.executor.internal.Cause cause)	The LiveObject was inserted.
boolean	onLeaseExpiry()	A callback invoked as part of an InvocableMap.EntryProcessor to perform custom lease expiry operations when a lease has expired.
boolean	onMemberJoined()	A callback invoked as part of an InvocableMap.EntryProcessor to perform custom operations when the Member has joined the cluster.
boolean	onMemberLeaving()	A callback invoked as part of an InvocableMap.EntryProcessor to perform custom operations when the Member is leaving the cluster.
boolean	onMemberLeft()	A callback invoked as part of an InvocableMap.EntryProcessor to perform custom operations when the Member is leaving the cluster.
ComposableContinuation	onUpdated(CacheService service, InvocableMap.Entry entry, com.oracle.coherence.concurrent.executor.internal.Cause cause)	The LiveObject was updated.
void	readExternal(PofReader in)	Restore the contents of a user type instance by reading its state using the specified PofReader object.
void	readExternal(DataInput in)	Restore the contents of this object by loading the object's state from the passed DataInput object.
void	renew()	Renews the lease for some period of time.
void	setFreeMemory(long cFreeMemory)	Sets the free memory as reported by Runtime.freeMemory().
void	setMaxMemory(long cMaxMemory)	Sets the maximum memory as reported by Runtime.maxMemory().
void	setState(TaskExecutorService.ExecutorInfo.State state)	Sets the current TaskExecutorService.ExecutorInfo.State of the Executor.
void	setTasksCompletedCount(long cTasksCompleted)	Sets the number of completed tasks.
void	setTasksFailedCount(long cTasksFailed)	Sets the number of task failures.
void	setTasksInProgressCount(long cTasksInProgress)	Sets the number of tasks currently in progress.
void	setTotalMemory(long cTotalMemory)	Sets the total memory as reported by Runtime.totalMemory().
String	toString()
void	touch()	Touches the last update time for the TaskExecutorService.ExecutorInfo.
void	writeExternal(PofWriter out)	Save the contents of a POF user type instance by writing its state using the specified PofWriter object.
void	writeExternal(DataOutput out)	Save the contents of this object by storing the object's state into the passed DataOutput object.

Methods inherited from class com.tangosol.io.AbstractEvolvable

getDataVersion, getFutureData, setDataVersion, setFutureData

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.tangosol.io.Evolvable

getDataVersion, getFutureData, setDataVersion, setFutureData

Field Detail

LEASE_DURATION_MS

public static long LEASE_DURATION_MS

The duration of a lease for Executors.

When TaskExecutorService.ExecutorInfo for an Executor has not been updated for the lease duration time, the Executor is considered to be offline and should automatically be de-registered.

VERSION

protected static int VERSION

PortableObject version.

m_state

protected TaskExecutorService.ExecutorInfo.State m_state

The TaskExecutorService.ExecutorInfo.State of the Executor.

m_sIdentity

protected String m_sIdentity

The identity of the TaskExecutorService.Registration.

m_optionsByType

protected OptionsByType<TaskExecutorService.Registration.Option> m_optionsByType

The TaskExecutorService.Registration.Options for the Executor.

m_ldtUpdate

protected long m_ldtUpdate

The cluster time when the TaskExecutorService.ExecutorInfo was last updated.

m_ldtJoined

protected long m_ldtJoined

The cluster time when the TaskExecutorService.ExecutorInfo joined the service.

m_cMaxMemory

protected long m_cMaxMemory

The maximum memory as reported by Runtime.maxMemory().

m_cTotalMemory

protected long m_cTotalMemory

The total memory as reported by Runtime.totalMemory().

m_cFreeMemory

protected long m_cFreeMemory

The free memory as reported by Runtime.freeMemory().

m_cCompleted

protected long m_cCompleted

The completed tasks count.

m_cRejected

protected long m_cRejected

The rejected tasks count.

m_cInProgress

protected long m_cInProgress

The tasks that are in progress count.

Constructor Detail

ClusteredExecutorInfo

public ClusteredExecutorInfo()

Constructs a ClusteredExecutorInfo (for serialization support).

ClusteredExecutorInfo

public ClusteredExecutorInfo(String sIdentity,
                             long ldtUpdate,
                             long cMaxMemory,
                             long totalMemory,
                             long freeMemory,
                             OptionsByType<TaskExecutorService.Registration.Option> optionsByType)

Constructs a ClusteredExecutorInfo with the specified parameters.

Parameters:

sIdentity - the identity

ldtUpdate - the time since the epoc when the TaskExecutorService.ExecutorInfo was last updated

cMaxMemory - the maximum memory as reported by Runtime.maxMemory()

totalMemory - the total memory as reported by Runtime.totalMemory()

freeMemory - the free memory as reported by Runtime.freeMemory()

optionsByType - the TaskExecutorService.Registration.Options for the Executor

Method Detail

touch

public void touch()

Touches the last update time for the TaskExecutorService.ExecutorInfo.

getId

public String getId()

Description copied from interface: TaskExecutorService.ExecutorInfo

Obtains the unique identity for the ExecutorService.

Specified by:

getId in interface TaskExecutorService.ExecutorInfo

Returns:

the unique identity

getState

public TaskExecutorService.ExecutorInfo.State getState()

Obtains the current TaskExecutorService.ExecutorInfo.State of the Executor.

Specified by:

getState in interface TaskExecutorService.ExecutorInfo

Returns:

the current TaskExecutorService.ExecutorInfo.State

getLastUpdateTime

public long getLastUpdateTime()

Description copied from interface: TaskExecutorService.ExecutorInfo

Obtains the time since the epoch when the TaskExecutorService.ExecutorInfo was last updated.

Specified by:

getLastUpdateTime in interface TaskExecutorService.ExecutorInfo

Returns:

the time since the epoch for the last update

getJoinTime

public long getJoinTime()

Description copied from interface: TaskExecutorService.ExecutorInfo

Returns the time since the epoch when the associated executor joined the service.

Specified by:

getJoinTime in interface TaskExecutorService.ExecutorInfo

Returns:

the time since the epoch when the associated executor joined the service

getMaxMemory

public long getMaxMemory()

Description copied from interface: TaskExecutorService.ExecutorInfo

The last reported maximum memory by Runtime.maxMemory() available to the ExecutorService.

Specified by:

getMaxMemory in interface TaskExecutorService.ExecutorInfo

Returns:

the maximum memory (in bytes)

getTotalMemory

public long getTotalMemory()

Description copied from interface: TaskExecutorService.ExecutorInfo

The last reported total memory by Runtime.totalMemory() available to the ExecutorService.

Specified by:

getTotalMemory in interface TaskExecutorService.ExecutorInfo

Returns:

the total memory (in bytes)

getFreeMemory

public long getFreeMemory()

Description copied from interface: TaskExecutorService.ExecutorInfo

The last reported free memory by Runtime.freeMemory() available to the ExecutorService.

Specified by:

getFreeMemory in interface TaskExecutorService.ExecutorInfo

Returns:

the free memory (in bytes)

getOption

public <T extends TaskExecutorService.Registration.Option> T getOption(Class<T> clzOfOption,
                                                                       T defaultIfNotFound)

Description copied from interface: TaskExecutorService.ExecutorInfo

Obtains the TaskExecutorService.Registration.Option of the specified class when the ExecutorService was registered, or the default value if not found.

Specified by:

getOption in interface TaskExecutorService.ExecutorInfo

Type Parameters:

T - the type of the TaskExecutorService.Registration.Option

Parameters:

clzOfOption - the class of TaskExecutorService.Registration.Option

defaultIfNotFound - the value to return if not found

Returns:

a TaskExecutorService.Registration.Option

getImplVersion

public int getImplVersion()

Description copied from class: AbstractEvolvable

Determine the serialization version supported by the implementing class.

Specified by:

getImplVersion in interface Evolvable

Specified by:

getImplVersion in class AbstractEvolvable

Returns:

the serialization version supported by this object

setState

public void setState(TaskExecutorService.ExecutorInfo.State state)

Sets the current TaskExecutorService.ExecutorInfo.State of the Executor.

Parameters:

state - the desired TaskExecutorService.ExecutorInfo.State

getTasksCompletedCount

public long getTasksCompletedCount()

Return the number of completed tasks.

Returns:

the number of completed tasks

getTasksRejectedCount

public long getTasksRejectedCount()

Return the number rejected tasks.

Returns:

the number rejected tasks

getTasksInProgressCount

public long getTasksInProgressCount()

Return the number of tasks currently in progress.

Returns:

the number of tasks currently in progress

setMaxMemory

public void setMaxMemory(long cMaxMemory)

Sets the maximum memory as reported by Runtime.maxMemory().

Parameters:

cMaxMemory - the maximum memory

setTotalMemory

public void setTotalMemory(long cTotalMemory)

Sets the total memory as reported by Runtime.totalMemory().

Parameters:

cTotalMemory - the total memory

setFreeMemory

public void setFreeMemory(long cFreeMemory)

Sets the free memory as reported by Runtime.freeMemory().

Parameters:

cFreeMemory - the free memory

setTasksCompletedCount

public void setTasksCompletedCount(long cTasksCompleted)

Sets the number of completed tasks.

Parameters:

cTasksCompleted - the number of completed tasks

setTasksFailedCount

public void setTasksFailedCount(long cTasksFailed)

Sets the number of task failures.

Parameters:

cTasksFailed - the number of failed tasks

setTasksInProgressCount

public void setTasksInProgressCount(long cTasksInProgress)

Sets the number of tasks currently in progress.

Parameters:

cTasksInProgress - the number of tasks in progress

getExecutorName

public String getExecutorName()

Return the logical name of this ClusteredExecutorInfo.

Returns:

the logical name of this ClusteredExecutorInfo

getDescription

public String getDescription()

Return the description of the ClusteredExecutorInfo.

Returns:

the description of the ClusteredExecutorInfo

Since:

22.06

toString

public String toString()

Overrides:

toString in class Object

getLeaseExpiryTime

public long getLeaseExpiryTime()

Description copied from interface: com.oracle.coherence.concurrent.executor.internal.Leased

Obtains the time the lease will expiry (in milliseconds since the epoc).

Specified by:

getLeaseExpiryTime in interface com.oracle.coherence.concurrent.executor.internal.Leased

Returns:

the time in milliseconds since the epoc

renew

public void renew()

Description copied from interface: com.oracle.coherence.concurrent.executor.internal.Leased

Renews the lease for some period of time.

Specified by:

renew in interface com.oracle.coherence.concurrent.executor.internal.Leased

onLeaseExpiry

public boolean onLeaseExpiry()

Description copied from interface: com.oracle.coherence.concurrent.executor.internal.Leased

A callback invoked as part of an InvocableMap.EntryProcessor to perform custom lease expiry operations when a lease has expired.

Specified by:

onLeaseExpiry in interface com.oracle.coherence.concurrent.executor.internal.Leased

Returns:

true if the Leased state was mutated and should be saved, false otherwise

onInserted

public ComposableContinuation onInserted(CacheService service,
                                         InvocableMap.Entry entry,
                                         com.oracle.coherence.concurrent.executor.internal.Cause cause)

Description copied from interface: com.oracle.coherence.concurrent.executor.internal.LiveObject

The LiveObject was inserted.

Specified by:

onInserted in interface com.oracle.coherence.concurrent.executor.internal.LiveObject

Parameters:

service - the CacheService for the LiveObject

entry - the entry being inserted

cause - the Cause of the Event

Returns:

an optional ComposableContinuation to be performed asynchronously for the LiveObject (may be null)

onUpdated

public ComposableContinuation onUpdated(CacheService service,
                                        InvocableMap.Entry entry,
                                        com.oracle.coherence.concurrent.executor.internal.Cause cause)

Description copied from interface: com.oracle.coherence.concurrent.executor.internal.LiveObject

The LiveObject was updated.

This callback is invoked against the updated value, not the original value. The original value is available via the provided Event.

Specified by:

onUpdated in interface com.oracle.coherence.concurrent.executor.internal.LiveObject

Parameters:

service - the CacheService for the LiveObject

entry - the entry being updated

cause - the Cause of the Event

Returns:

an optional ComposableContinuation to be performed asynchronously for the LiveObject (may be null)

onDeleted

public ComposableContinuation onDeleted(CacheService service,
                                        InvocableMap.Entry entry,
                                        com.oracle.coherence.concurrent.executor.internal.Cause cause)

Description copied from interface: com.oracle.coherence.concurrent.executor.internal.LiveObject

The LiveObject was deleted.

Specified by:

onDeleted in interface com.oracle.coherence.concurrent.executor.internal.LiveObject

Parameters:

service - the CacheService for the LiveObject

entry - the entry being deleted

cause - the Cause of the Event

Returns:

an optional ComposableContinuation to be performed asynchronously for the LiveObject (may be null)

getUid

public UID getUid()

Description copied from interface: com.oracle.coherence.concurrent.executor.internal.ClusterMemberAware

The UID of the Member for which this object wishes to receive membership events. May return null which means do not receive membership events.

Specified by:

getUid in interface com.oracle.coherence.concurrent.executor.internal.ClusterMemberAware

Returns:

a UID

onMemberJoined

public boolean onMemberJoined()

Description copied from interface: com.oracle.coherence.concurrent.executor.internal.ClusterMemberAware

A callback invoked as part of an InvocableMap.EntryProcessor to perform custom operations when the Member has joined the cluster.

Specified by:

onMemberJoined in interface com.oracle.coherence.concurrent.executor.internal.ClusterMemberAware

Returns:

true if the ClusterMemberAware state was mutated and should be saved, false otherwise

See Also:

MemberListener.memberJoined(MemberEvent)

onMemberLeaving

public boolean onMemberLeaving()

Description copied from interface: com.oracle.coherence.concurrent.executor.internal.ClusterMemberAware

A callback invoked as part of an InvocableMap.EntryProcessor to perform custom operations when the Member is leaving the cluster.

Specified by:

onMemberLeaving in interface com.oracle.coherence.concurrent.executor.internal.ClusterMemberAware

Returns:

true if the ClusterMemberAware state was mutated and should be saved, false otherwise

onMemberLeft

public boolean onMemberLeft()

Description copied from interface: com.oracle.coherence.concurrent.executor.internal.ClusterMemberAware

A callback invoked as part of an InvocableMap.EntryProcessor to perform custom operations when the Member is leaving the cluster.

See MemberListener.memberLeft(MemberEvent).

Specified by:

onMemberLeft in interface com.oracle.coherence.concurrent.executor.internal.ClusterMemberAware

Returns:

true if the ClusterMemberAware state was mutated and should be saved, false otherwise

readExternal

public void readExternal(DataInput in)
                  throws IOException

Description copied from interface: ExternalizableLite

Restore the contents of this object by loading the object's state from the passed DataInput object.

Specified by:

readExternal in interface ExternalizableLite

Parameters:

in - the DataInput stream to read data from in order to restore the state of this object

Throws:

IOException - if an I/O exception occurs

NotActiveException - if the object is not in its initial state, and therefore cannot be deserialized into

writeExternal

public void writeExternal(DataOutput out)
                   throws IOException

Description copied from interface: ExternalizableLite

Save the contents of this object by storing the object's state into the passed DataOutput object.

Specified by:

writeExternal in interface ExternalizableLite

Parameters:

out - the DataOutput stream to write the state of this object to

Throws:

IOException - if an I/O exception occurs

readExternal

public void readExternal(PofReader in)
                  throws IOException

Description copied from interface: PortableObject

Restore the contents of a user type instance by reading its state using the specified PofReader object.

Specified by:

readExternal in interface PortableObject

Parameters:

in - the PofReader from which to read the object's state

Throws:

IOException - if an I/O error occurs

writeExternal

public void writeExternal(PofWriter out)
                   throws IOException

Description copied from interface: PortableObject

Save the contents of a POF user type instance by writing its state using the specified PofWriter object.

Specified by:

writeExternal in interface PortableObject

Parameters:

out - the PofWriter to which to write the object's state

Throws:

IOException - if an I/O error occurs