Package org.jgroups.protocols

Class COUNTER.SyncCounterImpl

java.lang.Object

org.jgroups.protocols.COUNTER.SyncCounterImpl

All Implemented Interfaces:

Counter, SyncCounter

Enclosing class:

COUNTER

private static class COUNTER.SyncCounterImpl
extends java.lang.Object
implements Counter

Field Summary

Fields

Modifier and Type	Field	Description
private AsyncCounter	counter

Constructor Summary

Constructors

Modifier	Constructor	Description
private	SyncCounterImpl(AsyncCounter counter)

Method Summary

Modifier and Type	Method	Description
long	addAndGet(long delta)	Atomically adds the given value to the current value.
AsyncCounter	async()
long	compareAndSwap(long expect, long update)	Atomically updates the counter using a compare-and-swap operation.
long	get()	Gets the current value of the counter
java.lang.String	getName()
void	set(long new_value)	Sets the counter to a new value
java.lang.String	toString()
<T extends Streamable> T	update(CounterFunction<T> updateFunction)	Atomically updates the counter's value.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgroups.blocks.atomic.SyncCounter

compareAndSet, decrementAndGet, incrementAndGet

Field Detail

counter

private final AsyncCounter counter

Constructor Detail

SyncCounterImpl

private SyncCounterImpl(AsyncCounter counter)

Method Detail

getName

public java.lang.String getName()

Specified by:

getName in interface SyncCounter

get

public long get()

Description copied from interface: SyncCounter

Gets the current value of the counter

Specified by:

get in interface SyncCounter

Returns:

The current value

set

public void set(long new_value)

Description copied from interface: SyncCounter

Sets the counter to a new value

Specified by:

set in interface SyncCounter

Parameters:

new_value - The new value

compareAndSwap

public long compareAndSwap(long expect,
                           long update)

Description copied from interface: SyncCounter

Atomically updates the counter using a compare-and-swap operation.

Specified by:

compareAndSwap in interface Counter

Specified by:

compareAndSwap in interface SyncCounter

Parameters:

expect - The expected value of the counter

update - The new value of the counter

Returns:

The previous value of the counter

addAndGet

public long addAndGet(long delta)

Description copied from interface: SyncCounter

Atomically adds the given value to the current value.

Specified by:

addAndGet in interface SyncCounter

Parameters:

delta - the value to add

Returns:

the updated value

update

public <T extends Streamable> T update(CounterFunction<T> updateFunction)

Description copied from interface: SyncCounter

Atomically updates the counter's value.

Both CounterFunction and return value must implement Streamable to be sent over the network. The function should not block thread since it can cause deadlocks neither invoke any operation over the SyncCounter.

The CounterView is a copy of the counter's value and the last CounterView.set(long) will be applied to the counter.

Specified by:

update in interface SyncCounter

Type Parameters:

T - The return value type.

Parameters:

updateFunction - The update CounterFunction.

Returns:

The function's return value.

See Also:

CounterFunction, CounterView, LongSizeStreamable

async

public AsyncCounter async()

Specified by:

async in interface Counter

Specified by:

async in interface SyncCounter

Returns:

an asynchronous wrapper around this instance.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object