/*
* Copyright (c) 2014 Red Hat, Inc. and others
*
* This program and the accompanying materials are made available under the
* terms of the Eclipse Public License 2.0 which is available at
* http://www.eclipse.org/legal/epl-2.0, or the Apache License, Version 2.0
* which is available at https://www.apache.org/licenses/LICENSE-2.0.
*
* SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
*/
package io.vertx.core.shareddata;
import io.vertx.codegen.annotations.VertxGen;
import io.vertx.core.AsyncResult;
import io.vertx.core.Handler;
An asynchronous counter that can be used to across the cluster to maintain a consistent count.
Author: Tim Fox
/**
* An asynchronous counter that can be used to across the cluster to maintain a consistent count.
* <p>
*
*
* @author <a href="http://tfox.org">Tim Fox</a>
*/
@VertxGen
public interface Counter {
Get the current value of the counter
Params: - resultHandler – handler which will be passed the value
/**
* Get the current value of the counter
*
* @param resultHandler handler which will be passed the value
*/
void get(Handler<AsyncResult<Long>> resultHandler);
Increment the counter atomically and return the new count
Params: - resultHandler – handler which will be passed the value
/**
* Increment the counter atomically and return the new count
*
* @param resultHandler handler which will be passed the value
*/
void incrementAndGet(Handler<AsyncResult<Long>> resultHandler);
Increment the counter atomically and return the value before the increment.
Params: - resultHandler – handler which will be passed the value
/**
* Increment the counter atomically and return the value before the increment.
*
* @param resultHandler handler which will be passed the value
*/
void getAndIncrement(Handler<AsyncResult<Long>> resultHandler);
Decrement the counter atomically and return the new count
Params: - resultHandler – handler which will be passed the value
/**
* Decrement the counter atomically and return the new count
*
* @param resultHandler handler which will be passed the value
*/
void decrementAndGet(Handler<AsyncResult<Long>> resultHandler);
Add the value to the counter atomically and return the new count
Params: - value – the value to add
- resultHandler – handler which will be passed the value
/**
* Add the value to the counter atomically and return the new count
*
* @param value the value to add
* @param resultHandler handler which will be passed the value
*/
void addAndGet(long value, Handler<AsyncResult<Long>> resultHandler);
Add the value to the counter atomically and return the value before the add
Params: - value – the value to add
- resultHandler – handler which will be passed the value
/**
* Add the value to the counter atomically and return the value before the add
*
* @param value the value to add
* @param resultHandler handler which will be passed the value
*/
void getAndAdd(long value, Handler<AsyncResult<Long>> resultHandler);
Set the counter to the specified value only if the current value is the expectec value. This happens
atomically.
Params: - expected – the expected value
- value – the new value
- resultHandler – the handler will be passed true on success
/**
* Set the counter to the specified value only if the current value is the expectec value. This happens
* atomically.
*
* @param expected the expected value
* @param value the new value
* @param resultHandler the handler will be passed true on success
*/
void compareAndSet(long expected, long value, Handler<AsyncResult<Boolean>> resultHandler);
}