CountingPoisonPill (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.dataflow.operator
[Java] Class CountingPoisonPill

java.lang.Object
  groovyx.gpars.dataflow.operator.PoisonPill
      groovyx.gpars.dataflow.operator.CountingPoisonPill

public final class CountingPoisonPill
extends PoisonPill

Represents a non-immediate PoisonPill that counts stopped operators and can be used to wait for all the operators to terminate.

Field Summary
`private PoisonTrackCounter`	`poisonTrackCounter`

Fields inherited from class PoisonPill
immediate, immediateInstance, ourInstance

Constructor Summary
`CountingPoisonPill(int count)`

Method Summary
`void`	`countDown()`
`Promise`	`getTermination()`
`void`	`join()`
`void`	`join(long timeout, java.util.concurrent.TimeUnit unit)` Retrieves the promise for termination

Methods inherited from class PoisonPill
countDown, getImmediateInstance, getInstance, isImmediate

Field Detail

private final PoisonTrackCounter poisonTrackCounter

Constructor Detail

public CountingPoisonPill(int count)

Method Detail

@java.lang.Override
void countDown()

public Promise getTermination()

public void join()

public void join(long timeout, java.util.concurrent.TimeUnit unit)

Retrieves the promise for termination

Returns:: A Promise instance that will be bound when all the requested dataflow processors have been terminated