com.fr.third.jgroups.blocks.atomic

类 CounterService

java.lang.Object

com.fr.third.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.

从以下版本开始:

3.0.0

作者:

Bela Ban

字段概要

字段

限定符和类型	字段和说明
protected JChannel	ch
protected COUNTER	counter_prot

构造器概要

构造器

构造器和说明
CounterService(JChannel ch)

方法概要

方法

限定符和类型	方法和说明
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)

从类继承的方法 java.lang.Object

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

字段详细资料

ch

protected JChannel ch

counter_prot

protected COUNTER counter_prot

构造器详细资料

CounterService

public CounterService(JChannel ch)

方法详细资料

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

参数:

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

返回:

The counter implementation

deleteCounter

public void deleteCounter(java.lang.String name)

Deletes a counter instance (on the coordinator)

参数:

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