private class ServerImpl.SessionManagedInvoker extends ServerImpl.AsyncInvoker implements java.lang.Runnable
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.
|
Modifier | Constructor and Description |
---|---|
private |
SessionManagedInvoker() |
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 . |
isTerminated, terminate
private java.util.ArrayDeque<AsyncRequestImpl> queue
private AsyncRequestImpl request
public void invoke(AsyncRequestImpl request)
async queue
; from there, a specialized thread will pick it up and execute
it.invoke
in class ServerImpl.AsyncInvoker
request
- The async request to be executed.public void start()
queue
.start
in class ServerImpl.AsyncInvoker
public void run()
run
in interface java.lang.Runnable
public boolean cancelRequests()
cancelRequests
in class ServerImpl.AsyncInvoker
true
if cancellation was possible.