javax.realtime

Class AsyncObjectEventHandler<P>

java.lang.Object

javax.realtime.AsyncBaseEventHandler

javax.realtime.AsyncObjectEventHandler<P>

Type Parameters:

P - is the type of Object received.

All Implemented Interfaces:

java.lang.Runnable, Releasable<Timable,TimeDispatcher>, Schedulable, Subsumable<Schedulable>, Timable

Direct Known Subclasses:

BoundAsyncObjectEventHandler

public class AsyncObjectEventHandler<P>
extends AsyncBaseEventHandler

A version of AsyncBaseEventHandler that carries an Object value as payload.

Since:

RTSJ 2.0

Constructor Summary

Constructors

Constructor and Description
AsyncObjectEventHandler() Creates an instance of AsyncObjectEventHandler (AOEH) with default values for all parameters.
AsyncObjectEventHandler(java.util.function.Consumer<P> logic) Calling this constructor is equivalent to calling AsyncObjectEventHandler(SchedulingParameters, ReleaseParameters, MemoryParameters, MemoryArea, ReleaseRunner, Consumer) with arguments (null, null, null, null, null, null, logic).
AsyncObjectEventHandler(SchedulingParameters scheduling, ReleaseParameters<?> release) Calling this constructor is equivalent to calling AsyncObjectEventHandler(SchedulingParameters, ReleaseParameters, MemoryParameters, MemoryArea, ReleaseRunner, Consumer) with arguments (scheduling, release, null, null, null, null)
AsyncObjectEventHandler(SchedulingParameters scheduling, ReleaseParameters<?> release, java.util.function.Consumer<P> logic) Calling this constructor is equivalent to calling AsyncObjectEventHandler(SchedulingParameters, ReleaseParameters, MemoryParameters, MemoryArea, ReleaseRunner, Consumer) with arguments (scheduling, release, null, null, null, logic).
AsyncObjectEventHandler(SchedulingParameters scheduling, ReleaseParameters<?> release, MemoryParameters memory, MemoryArea area, ReleaseRunner runner, java.util.function.Consumer<P> logic) Creates an asynchronous event handler that receives an Object payload with each fire.

Method Summary

Modifier and Type	Method and Description
void	handleAsyncEvent(P payload) This method holds the logic which is to be executed when any AsyncEvent with which this handler is associated is fired.
P	peekPending() Determines the next value queued for handling.

Methods inherited from class javax.realtime.AsyncBaseEventHandler

addIfFeasible, addToFeasibility, finalize, getAndClearPendingFireCount, getAndDecrementPendingFireCount, getDispatcher, getMemoryArea, getMemoryParameters, getPendingFireCount, getProcessingGroupParameters, getReleaseParameters, getScheduler, getSchedulingParameters, isDaemon, mayUseHeap, removeFromFeasibility, run, setDaemon, setIfFeasible, setIfFeasible, setIfFeasible, setIfFeasible, setIfFeasible, setMemoryParameters, setMemoryParametersIfFeasible, setProcessingGroupParameters, setProcessingGroupParametersIfFeasible, setReleaseParameters, setReleaseParametersIfFeasible, setScheduler, setScheduler, setSchedulingParameters, setSchedulingParametersIfFeasible, subsumes

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncObjectEventHandler

public AsyncObjectEventHandler(SchedulingParameters scheduling,
                               ReleaseParameters<?> release,
                               MemoryParameters memory,
                               MemoryArea area,
                               ReleaseRunner runner,
                               java.util.function.Consumer<P> logic)
                        throws StaticIllegalArgumentException

Creates an asynchronous event handler that receives an Object payload with each fire.

Parameters:

scheduling - Parameter for scheduling the new handler (and possibly other instances of Schedulable). When scheduling is null and the creator is an instance of Schedulable, SchedulingParameters is a clone of the creator's value created in the same memory area as this. When scheduling is null and the creator is a task that is not an instance of Schedulable, the contents and type of the new SchedulingParameters object are governed by the associated scheduler.

release - Parameter for scheduling the new handler (and possibly other instances of Schedulable). When release is null the new AsyncEventHandler will use a clone of the default ReleaseParameters for the associated scheduler created in the memory area that contains the AsyncEventHandler object.

memory - Parameter for scheduling the new handler (and possibly other instances of Schedulable). When memory is null, the new AsyncEventHandler receives null value for its memory parameters, and the amount or rate of memory allocation for the new handler is unrestricted.

area - The initial memory area of this handler.

runner - Logic to be executed by handleAsyncEvent(P)

logic - The logic to run for each fire. When logic is null, the handleAsyncEvent method in the new object will serve as its logic.

Throws:

StaticIllegalArgumentException - when the event queue overflow policy is QueueOverflowPolicy.DISABLE.

AsyncObjectEventHandler

public AsyncObjectEventHandler(SchedulingParameters scheduling,
                               ReleaseParameters<?> release,
                               java.util.function.Consumer<P> logic)
                        throws StaticIllegalArgumentException

Calling this constructor is equivalent to calling AsyncObjectEventHandler(SchedulingParameters, ReleaseParameters, MemoryParameters, MemoryArea, ReleaseRunner, Consumer) with arguments (scheduling, release, null, null, null, logic).

Throws:

StaticIllegalArgumentException

AsyncObjectEventHandler

public AsyncObjectEventHandler(SchedulingParameters scheduling,
                               ReleaseParameters<?> release)
                        throws StaticIllegalArgumentException

Calling this constructor is equivalent to calling AsyncObjectEventHandler(SchedulingParameters, ReleaseParameters, MemoryParameters, MemoryArea, ReleaseRunner, Consumer) with arguments (scheduling, release, null, null, null, null)

Throws:

StaticIllegalArgumentException

AsyncObjectEventHandler

public AsyncObjectEventHandler(java.util.function.Consumer<P> logic)

Calling this constructor is equivalent to calling AsyncObjectEventHandler(SchedulingParameters, ReleaseParameters, MemoryParameters, MemoryArea, ReleaseRunner, Consumer) with arguments (null, null, null, null, null, null, logic).

AsyncObjectEventHandler

public AsyncObjectEventHandler()

Creates an instance of AsyncObjectEventHandler (AOEH) with default values for all parameters.

See Also:

AsyncObjectEventHandler(SchedulingParameters, ReleaseParameters, MemoryParameters, MemoryArea, ReleaseRunner, Consumer)

Method Detail

handleAsyncEvent

public void handleAsyncEvent(P payload)

This method holds the logic which is to be executed when any AsyncEvent with which this handler is associated is fired. This method will be invoked repeatedly while fireCount_ is greater than zero.

The default implementation of this method either invokes the run method of the logic passed to the constructor of this handler, when it is an instance of Runnable or nothing, when logic is null.

This AOEH is a source of reference for its initial memory area while this AOEH is released.

All throwables from (or propagated through) handleAsyncEvent(P) are caught, a stack trace is printed and execution continues as if handleAsyncEvent(P) had returned normally.

Parameters:

payload - The data associated with the release being handled.

peekPending

public P peekPending()
              throws StaticIllegalStateException

Determines the next value queued for handling.

Returns:

the object reference at the head of the queue of object references to be passed to handleAsyncEvent(P)}.

Throws:

StaticIllegalStateException - when the fire count is zero.