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

Fields

Modifier and Type	Field and Description
protected Channel	ch
protected COUNTER	counter_prot

Constructor Summary

Constructors

Constructor and Description
CounterService(Channel ch)

Method Summary

Modifier and Type	Method and Description
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(Channel ch)

Methods inherited from class java.lang.Object

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

Field Detail

ch

protected Channel ch

counter_prot

protected COUNTER counter_prot

Constructor Detail

CounterService

public CounterService(Channel ch)

Method Detail

setChannel

public void setChannel(Channel 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()