org.apache.giraph.utils

Class ThreadLocalProgressCounter

java.lang.Object

java.lang.ThreadLocal<ProgressCounter>

org.apache.giraph.utils.ThreadLocalProgressCounter

public class ThreadLocalProgressCounter
extends ThreadLocal<ProgressCounter>

Makes a list of ProgressCounter accessible through a ThreadLocal.

Constructor Summary

Constructors

Constructor and Description
ThreadLocalProgressCounter()

Method Summary

Modifier and Type	Method and Description
long	getProgress() Sums the progress of all counters.
protected ProgressCounter	initialValue() Initializes a new counter, adds it to the list of counters and returns it.
void	reset() Removes all counters.

Methods inherited from class java.lang.ThreadLocal

get, remove, set, withInitial

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ThreadLocalProgressCounter

public ThreadLocalProgressCounter()

Method Detail

initialValue

protected ProgressCounter initialValue()

Initializes a new counter, adds it to the list of counters and returns it.

Overrides:

initialValue in class ThreadLocal<ProgressCounter>

Returns:

Progress counter.

getProgress

public long getProgress()

Sums the progress of all counters.

Returns:

Sum of all counters

reset

public void reset()

Removes all counters.