com.goldencode.p2j.util

Class ServerImpl.SessionFreeInvoker

java.lang.Object

com.goldencode.p2j.util.ServerImpl.AsyncInvoker

com.goldencode.p2j.util.ServerImpl.SessionFreeInvoker

Enclosing class:

ServerImpl

private class ServerImpl.SessionFreeInvoker
extends ServerImpl.AsyncInvoker

Asynchronous invoker implementation for Session-free operating mode. In this mode, each async request is executed in its separate thread.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Set<AsyncRequestImpl>	requests A set of running requests.

Constructor Summary

Constructors

Modifier	Constructor and Description
private	SessionFreeInvoker()

Method Summary

Modifier and Type	Method and Description
boolean	cancelRequests() Cancel all running requests by sending the STOP conditions to them.
void	invoke(AsyncRequestImpl request) Invoking an async request in State-free mode needs to request to be executed in its separated thread.
void	start() This is a no-op, as the State-free invoker doesn't need a dedicated thread.

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

requests

private java.util.Set<AsyncRequestImpl> requests

A set of running requests.

Constructor Detail

SessionFreeInvoker

private SessionFreeInvoker()

Method Detail

invoke

public void invoke(AsyncRequestImpl request)

Invoking an async request in State-free mode needs to request to be executed in its separated thread. For this, all running requests are registered in the requests set, to be able to cancel them.

Specified by:

invoke in class ServerImpl.AsyncInvoker

Parameters:

request - The request to be executed.

start

public void start()

This is a no-op, as the State-free invoker doesn't need a dedicated thread.

Specified by:

start in class ServerImpl.AsyncInvoker

cancelRequests

public boolean cancelRequests()

Cancel all running requests by sending the STOP conditions to them.

Specified by:

cancelRequests in class ServerImpl.AsyncInvoker

Returns:

true if cancel was possible.