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:

Runnable, Releasable<Timable,TimeDispatcher>, Schedulable, Timable

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(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, 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, Consumer<P> logic) Creates an asynchronous event handler that receives a Long payload with each fire.

Method Summary

Modifier and Type	Method and Description
protected int	getAndClearPendingFireCount() getAndClearPendingFireCount sets the pending fire count to zero and returns the original value.
protected int	getAndDecrementPendingFireCount() getAndDecrementPendingFireCount decrements the pending fire count and returns the original value.
protected int	getPendingFireCount() getPendingFireCount returns the current number of pending invocations to handleAsyncEvent().
void	handleAsyncEvent(P value) 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.
void	run() When an object implementing interface Runnable is used to create a thread, starting the thread causes the object's run method to be called in that separately executing thread.

Methods inherited from class javax.realtime.AsyncBaseEventHandler

addIfFeasible, addToFeasibility, finalize, getAndIncrementPendingFireCount, getDispatcher, getMemoryArea, getMemoryParameters, getProcessingGroupParameters, getReleaseParameters, getScheduler, getSchedulingParameters, isDaemon, removeFromFeasibility, setDaemon, setIfFeasible, setIfFeasible, setIfFeasible, setIfFeasible, setIfFeasible, setMemoryParameters, setMemoryParametersIfFeasible, setProcessingGroupParameters, setProcessingGroupParametersIfFeasible, setReleaseParameters, setReleaseParametersIfFeasible, setScheduler, setScheduler, setSchedulingParameters, setSchedulingParametersIfFeasible

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,
                               Consumer<P> logic)
                        throws StaticIllegalArgumentException

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

Throws:

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

StaticUnsupportedOperationException - every time, since it is not implemented yet.

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.

AsyncObjectEventHandler

public AsyncObjectEventHandler(SchedulingParameters scheduling,
                               ReleaseParameters release,
                               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:

StaticUnsupportedOperationException - every time, since it is not implemented yet.

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:

StaticUnsupportedOperationException - every time, since it is not implemented yet.

StaticIllegalArgumentException

AsyncObjectEventHandler

public AsyncObjectEventHandler(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).

Throws:

StaticUnsupportedOperationException - every time, since it is not implemented yet.

Parameters:

logic - It is the function to call on the object received.

AsyncObjectEventHandler

public AsyncObjectEventHandler()

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

Throws:

StaticUnsupportedOperationException - every time, since it is not implemented yet

See Also:

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

Method Detail

handleAsyncEvent

public void handleAsyncEvent(P value)

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 invokes the run method of any non-null logic instance passed to the constructor of this handler.

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.

Throws:

StaticUnsupportedOperationException - every time, since it is not implemented yet

peekPending

public P peekPending()
              throws StaticIllegalStateException

Determines the next value queued for handling.

Throws:

StaticIllegalStateException - when the fire count is zero.

Returns:

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

run

public final void run()

Description copied from interface: Runnable

When an object implementing interface Runnable is used to create a thread, starting the thread causes the object's run method to be called in that separately executing thread.

The general contract of the method run is that it may take any action whatsoever.

Throws:

UnsupportedOperationException - every time, since it is not implemented yet

See Also:

Thread.run()

getPendingFireCount

protected int getPendingFireCount()

Description copied from class: AsyncBaseEventHandler

getPendingFireCount returns the current number of pending invocations to handleAsyncEvent(). During the execution of handleAsyncEvent(), the fireCount is at least 1 unless it has been reset manually (by a call to getAndClearPendingFireCount() or getAndDecrementPendingFireCount()).

Overrides:

getPendingFireCount in class AsyncBaseEventHandler

Throws:

StaticUnsupportedOperationException - every time, since it is not implemented yet

Returns:

The current number of pending executions of handleAsyncEvent().

getAndDecrementPendingFireCount

protected int getAndDecrementPendingFireCount()

Description copied from class: AsyncBaseEventHandler

getAndDecrementPendingFireCount decrements the pending fire count and returns the original value.

Overrides:

getAndDecrementPendingFireCount in class AsyncBaseEventHandler

Throws:

StaticUnsupportedOperationException - every time, since it is not implemented yet

Returns:

the original fire count.

getAndClearPendingFireCount

protected int getAndClearPendingFireCount()

Description copied from class: AsyncBaseEventHandler

getAndClearPendingFireCount sets the pending fire count to zero and returns the original value.

Overrides:

getAndClearPendingFireCount in class AsyncBaseEventHandler

Throws:

StaticUnsupportedOperationException - every time, since it is not implemented yet

Returns:

the original fire count.