com.goldencode.p2j.util

Class ServerImpl.SessionManagedInvoker

java.lang.Object

com.goldencode.p2j.util.ServerImpl.AsyncInvoker

com.goldencode.p2j.util.ServerImpl.SessionManagedInvoker

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

ServerImpl

private class ServerImpl.SessionManagedInvoker
extends ServerImpl.AsyncInvoker
implements java.lang.Runnable

Asynchronous invoker implementation for Session-managed operating mode. In this mode, a separate thread is started which listens for async requests added to the queue, and executes them in a FIFO mode.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.ArrayDeque<AsyncRequestImpl>	queue Queue of async requests pending execution.
private AsyncRequestImpl	request The current async request being executed.

Constructor Summary

Constructors

Modifier	Constructor and Description
private	SessionManagedInvoker()

Method Summary

Modifier and Type	Method and Description
boolean	cancelRequests() Cancel all queued or running requests.
void	invoke(AsyncRequestImpl request) In Session-managed operating mode, invoking an async request means adding it to the async queue; from there, a specialized thread will pick it up and execute it.
void	run() Listens for incoming async requests and executes them in FIFO order.
void	start() In Session-managed operating mode, a dedicated thread is started which listens for async requests added to the queue.

Methods inherited from class com.goldencode.p2j.util.ServerImpl.AsyncInvoker

isTerminated, terminate

Methods inherited from class java.lang.Object

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

Field Detail

queue

private java.util.ArrayDeque<AsyncRequestImpl> queue

Queue of async requests pending execution.

request

private AsyncRequestImpl request

The current async request being executed.

Constructor Detail

SessionManagedInvoker

private SessionManagedInvoker()

Method Detail

invoke

public void invoke(AsyncRequestImpl request)

In Session-managed operating mode, invoking an async request means adding it to the async queue; from there, a specialized thread will pick it up and execute it.

Specified by:

invoke in class ServerImpl.AsyncInvoker

Parameters:

request - The async request to be executed.

start

public void start()

In Session-managed operating mode, a dedicated thread is started which listens for async requests added to the queue.

Specified by:

start in class ServerImpl.AsyncInvoker

run

public void run()

Listens for incoming async requests and executes them in FIFO order.

Specified by:

run in interface java.lang.Runnable

cancelRequests

public boolean cancelRequests()

Cancel all queued or running requests.

Specified by:

cancelRequests in class ServerImpl.AsyncInvoker

Returns:

true if cancellation was possible.