org.jgroups.blocks.atomic
Class CounterService

java.lang.Object
  org.jgroups.blocks.atomic.CounterService

public class CounterService
extends java.lang.Object

Provides a distributed counter (similar to AtomicLong) which can be atomically updated across a cluster.

Since:

3.0.0

Author:

Bela Ban

Field Summary

protected JChannel	ch
protected COUNTER	counter_prot

Constructor Summary

CounterService(JChannel ch)

Method Summary

void	deleteCounter(java.lang.String name) Deletes a counter instance (on the coordinator)
java.lang.String	dumpPendingRequests()
Counter	getOrCreateCounter(java.lang.String name, long initial_value) Returns an existing counter, or creates a new one if none exists
java.lang.String	printCounters()
void	setChannel(JChannel ch)

Methods inherited from class java.lang.Object

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

Field Detail

ch

protected JChannel ch

counter_prot

protected COUNTER counter_prot

Constructor Detail

CounterService

public CounterService(JChannel ch)

Method Detail

setChannel

public void setChannel(JChannel ch)

getOrCreateCounter

public Counter getOrCreateCounter(java.lang.String name,
                                  long initial_value)

Returns an existing counter, or creates a new one if none exists

Parameters:

name - Name of the counter, different counters have to have different names

initial_value - The initial value of a new counter if there is no existing counter. Ignored if the counter already exists

Returns:

The counter implementation

deleteCounter

public void deleteCounter(java.lang.String name)

Deletes a counter instance (on the coordinator)

Parameters:

name - The name of the counter. No-op if the counter doesn't exist

printCounters

public java.lang.String printCounters()

dumpPendingRequests

public java.lang.String dumpPendingRequests()