SequentialProcessingActor.Reaction (org.codehaus.gpars)

Overview

Package

Class

Deprecated

Index

Help

org.codehaus.gpars

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

groovyx.gpars.actor.impl
Class SequentialProcessingActor.Reaction

java.lang.Object
  groovyx.gpars.actor.impl.SequentialProcessingActor.Reaction

@SuppressWarnings({"InstanceVariableOfConcreteClass"})
class SequentialProcessingActor.Reaction

Buffers messages for the next continuation of an event-driven actor, handles timeouts and no-param continuations.

Field Summary
`private SequentialProcessingActor`	`actor`
`private groovy.lang.Closure`	`code`
`private boolean`	`codeNeedsArgument`
`private java.util.concurrent.atomic.AtomicBoolean`	`isReady`

Constructor Summary
`SequentialProcessingActor.Reaction(SequentialProcessingActor actor, boolean codeNeedsArgument, groovy.lang.Closure code)` Creates a new instance.

Method Summary
`boolean`	`isReady()` Indicates whether a message or a timeout has arrived.
`void`	`offer(ActorMessage actorMessage)`
`void`	`setTimeout(long timeout)`

Methods inherited from class java.lang.Object
java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()

Field Detail

private final SequentialProcessingActor actor

private final groovy.lang.Closure code

private final boolean codeNeedsArgument

private final java.util.concurrent.atomic.AtomicBoolean isReady

Constructor Detail

public SequentialProcessingActor.Reaction(SequentialProcessingActor actor, boolean codeNeedsArgument, groovy.lang.Closure code)

Creates a new instance.

Parameters:: actor - actor; codeNeedsArgument - Indicates, whether the provided code expects an argument; code - code to execute

Method Detail

public boolean isReady()

Indicates whether a message or a timeout has arrived.

public void offer(ActorMessage actorMessage)

public void setTimeout(long timeout)