public class PoisonPill extends java.lang.Object
Represents the poison for dataflow operators. After receiving the poison a dataflow operator will send the poisson to all its output channels and terminate. Non=immediate poison will allow selectors to keep processing all remaining inputs until these get also poisoned. There§s no difference in behavior between immediate and non=immediate poison pills when obtained bz an operator.
| Modifiers | Name | Description |
|---|---|---|
private boolean |
immediate |
|
private static PoisonPill |
immediateInstance |
|
private static PoisonPill |
ourInstance |
| Constructor and description |
|---|
PoisonPill
() |
PoisonPill
(boolean immediate) |
| Type | Name and description |
|---|---|
void |
countDown() |
static PoisonPill |
getImmediateInstance()Retrieves an immediate poison pill instance |
static PoisonPill |
getInstance()Retrieves a non-immediate poison pill instance |
boolean |
isImmediate() |
| Methods inherited from class | Name |
|---|---|
class java.lang.Object |
java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), 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() |
Retrieves an immediate poison pill instance
Retrieves a non-immediate poison pill instance
Copyright © 2008–2014 Václav Pech. All Rights Reserved.