PoisonTrackCounter (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 PoisonTrackCounter

java.lang.Object
  groovyx.gpars.dataflow.operator.PoisonTrackCounter

final class PoisonTrackCounter

A helper class used by poison messages to count terminated dataflow processors

Field Summary
`private java.util.concurrent.atomic.AtomicInteger`	`counter`
`private DataflowVariable`	`termination`

Constructor Summary
`PoisonTrackCounter(int count)`

Method Summary
`void`	`countDown()`
`Promise`	`getTermination()`
`void`	`join()` Blocks until the number of terminated operators reaches the number specified in the constructor
`void`	`join(long timeout, java.util.concurrent.TimeUnit unit)` Blocks until the number of terminated operators reaches the number specified in the constructor

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 java.util.concurrent.atomic.AtomicInteger counter

private final DataflowVariable termination

Constructor Detail

PoisonTrackCounter(int count)

Method Detail

void countDown()

public Promise getTermination()

public void join()

Blocks until the number of terminated operators reaches the number specified in the constructor

throws:: InterruptedException If the current thread gets interrupted during the blocking

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

Blocks until the number of terminated operators reaches the number specified in the constructor

throws:: InterruptedException If the current thread gets interrupted during the blocking

Parameters:: timeout - the maximum time to wait; unit - the time unit of the timeout argument