PoisonTrackCounter (org.codehaus.gpars)

Summary:
Field
Constructor
Method

| Detail:
Field
Constructor
Method

groovyx.gpars.dataflow.operator.PoisonTrackCounter

A helper class used by poison messages to count terminated dataflow processors
Authors:
Vaclav Pech

Field Summary

Fields
Modifiers	Name	Description
`private java.util.concurrent.atomic.AtomicInteger`	`counter`
`private DataflowVariable<java.lang.Boolean>`	`termination`

Constructor Summary

Constructors
Constructor and description
`PoisonTrackCounter (int count)`

Methods Summary

Methods
Type	Name and description
`void`	`countDown()`
`Promise<java.lang.Boolean>`	`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

Inherited Methods Summary

Inherited Methods
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()`

- Field Detail
  - private final java.util.concurrent.atomic.AtomicInteger counter
  - private final DataflowVariable<java.lang.Boolean> termination
- Constructor Detail
  - PoisonTrackCounter(int count)
- Method Detail
  - void countDown()
  - public Promise<java.lang.Boolean> 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

Summary:
Field
Constructor
Method

| Detail:
Field
Constructor
Method

Copyright © 2008–2014 Václav Pech. All Rights Reserved.