Package | Description |
---|---|
org.agilewiki.jactor |
Introduction to JActor
|
org.agilewiki.jactor.apc |
The apc package implements Asynchronous Procedure Calls (APC), or two-way messaging.
|
org.agilewiki.jactor.continuation | |
org.agilewiki.jactor.lpc |
Introducing JLPCActor--the Basic Actor
|
org.agilewiki.jactor.nbLock |
NBLock provides exclusive access to a resource without blocking a thread.
|
org.agilewiki.jactor.parallel |
Sending multiple requests to different actors and waiting for the responses only after all the requests have
been sent is the simplest form of parallel processing and is the focus of this package.
|
org.agilewiki.jactor.pubsub.publisher | |
org.agilewiki.jactor.pubsub.subscriber | |
org.agilewiki.jactor.simpleMachine |
You can think of a State Machine as a kind of computer.
|
Modifier and Type | Class and Description |
---|---|
class |
JANoResponse
Used with on-way messages (Events) to signal that no response is required.
|
Modifier and Type | Method and Description |
---|---|
void |
Actor.acceptRequest(APCRequestSource requestSource,
Request request,
RP rp)
Wraps and enqueues an unwrapped request in the requester's inbox.
|
void |
JAIterator.iterate(RP responseProcessor)
Iterates over the process method.
|
protected abstract void |
JAIterator.process(RP responseProcessor)
Perform an iteration.
|
Modifier and Type | Class and Description |
---|---|
class |
JARequest
Requests sent to a JAPCMailbox are wrapped by an JARequest.
|
Modifier and Type | Field and Description |
---|---|
RP |
JARequest.rp |
Constructor and Description |
---|
JARequest(RequestSource requestSource,
JLPCActor destinationActor,
Request unwrappedRequest,
RP rp,
Mailbox mailbox) |
Constructor and Description |
---|
Continuation(TargetActor targetActor,
RP _rp) |
Modifier and Type | Method and Description |
---|---|
void |
JLPCActor.acceptRequest(APCRequestSource apcRequestSource,
Request request,
RP rp)
Wraps and enqueues an unwrapped request in the requester's inbox.
|
abstract void |
Request.processRequest(JLPCActor targetActor,
RP rp) |
void |
Internals.send(Actor actor,
Object request,
RP rp)
Send a request to another actor.
|
protected void |
JLPCActor.send(Actor actor,
Request request,
RP rp)
Send a request to another actor.
|
void |
JLPCActor.SMBuilder.send(Actor actor,
Request request,
RP rp) |
void |
Request.send(APCRequestSource requestSource,
Actor targetActor,
RP<RESPONSE_TYPE> rp)
Send a request.
|
void |
Request.send(APCRequestSource requestSource,
TARGET_TYPE targetActor,
RP<RESPONSE_TYPE> rp)
Send a request.
|
Modifier and Type | Method and Description |
---|---|
void |
JANBLock.lock(RP rp) |
void |
Unlock.processRequest(JLPCActor targetActor,
RP rp) |
void |
Lock.processRequest(JLPCActor targetActor,
RP rp) |
void |
JANBLock.unlock(RP rp) |
Modifier and Type | Class and Description |
---|---|
class |
JAResponseCounter
Returns a response only when the expected number of responses are received.
|
class |
JAResponseCounter2
Counts the number of responses received
and responds with the count of requests sent when the iteration is finished.
|
class |
JAResponseCounter3
Counts the number of responses received
and responds with the count of requests sent when the iteration is finished.
|
Modifier and Type | Method and Description |
---|---|
void |
JAResponseCounter3.setup(RP xrp)
Initialize.
|
Constructor and Description |
---|
JAResponseCounter(int max,
RP rp)
Create a JAResponseCounter.
|
JAResponseCounter2(RP xrp)
Create a PubSubResponseProcessor.
|
Modifier and Type | Method and Description |
---|---|
void |
Unsubscribe.processRequest(JLPCActor targetActor,
RP rp) |
void |
Subscribe.processRequest(JLPCActor targetActor,
RP rp) |
void |
Publish.processRequest(JLPCActor targetActor,
RP rp) |
void |
GetSubscriber.processRequest(JLPCActor targetActor,
RP rp) |
void |
Publisher.publish(Request publishRequest,
RP rp)
Publish a request to all the appropriate subscribers.
|
void |
JAPublisher.publish(Request publishRequest,
RP rp)
Publish a request to all the appropriate subscribers.
|
void |
JAPublisher.unsubscribed(Publisher publisher,
RP rp)
This actor's subscription has been dropped.
|
Modifier and Type | Method and Description |
---|---|
void |
Unsubscribed.processRequest(JLPCActor targetActor,
RP rp) |
void |
Subscribed.processRequest(JLPCActor targetActor,
RP rp) |
void |
Subscriber.unsubscribed(Publisher publisher,
RP rp)
This actor's subscription has been dropped.
|
void |
JASubscriber.unsubscribed(Publisher publisher,
RP rp)
This actor's subscription has been dropped.
|
Modifier and Type | Class and Description |
---|---|
class |
ExtendedResponseProcessor<RESPONSE_TYPE>
Supports processing sensitive to how a response is returned.
|
Modifier and Type | Method and Description |
---|---|
void |
_SMBuilder.call(Object request,
RP rp)
Instantiate and execute a state machine.
|
void |
_SMBuilder.call(RP rp)
Instantiate and execute a state machine.
|
void |
_SetV.call(SimpleMachine stateMachine,
RP rp)
Perform the operation.
|
void |
_SetF.call(SimpleMachine stateMachine,
RP rp)
Perform the operation.
|
void |
_Send.call(SimpleMachine stateMachine,
RP rp)
Perform the operation.
|
void |
_ReturnV.call(SimpleMachine stateMachine,
RP rp)
Perform the operation.
|
void |
_ReturnF.call(SimpleMachine stateMachine,
RP rp)
Perform the operation.
|
void |
_Operation.call(SimpleMachine stateMachine,
RP rp)
Perform the operation.
|
void |
_Iterator.call(SimpleMachine stateMachine,
RP rp)
Perform the operation.
|
void |
_IfV.call(SimpleMachine stateMachine,
RP rp)
Perform the operation.
|
void |
_IfF.call(SimpleMachine stateMachine,
RP rp)
Perform the operation.
|
void |
_Goto.call(SimpleMachine stateMachine,
RP rp)
Perform the operation.
|
void |
_Call.call(SimpleMachine stateMachine,
RP rp)
Perform the operation.
|
void |
SimpleMachine.execute(Object request,
RP rp)
Executes the state machine.
|
void |
_Iterator.iterate(RP responseProcessor) |
abstract void |
_SMBuilder.send(Actor actor,
Request request,
RP rp)
Send a request to an actor.
|
void |
SimpleMachine.send(Actor actor,
Request request,
RP rp)
Send a request to an actor.
|
Copyright © 2012. All Rights Reserved.