com.github.davidmoten.rx.util

Class BackpressureUtils

java.lang.Object

com.github.davidmoten.rx.util.BackpressureUtils

public final class BackpressureUtils
extends Object

Utility functions for use with backpressure.

Method Summary

Modifier and Type	Method and Description
static <T> long	getAndAddRequest(AtomicLongFieldUpdater<T> requested, T object, long n) Adds n to requested field and returns the value prior to addition once the addition is successful (uses CAS semantics).
static long	getAndAddRequest(AtomicLong requested, long n) Adds n to requested and returns the value prior to addition once the addition is successful (uses CAS semantics).

Methods inherited from class java.lang.Object

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

Method Detail

getAndAddRequest

public static <T> long getAndAddRequest(AtomicLongFieldUpdater<T> requested,
                                        T object,
                                        long n)

Adds n to requested field and returns the value prior to addition once the addition is successful (uses CAS semantics). If overflows then sets requested field to Long.MAX_VALUE.

Type Parameters:

T - then type of the volatile being updated

Parameters:

requested - atomic field updater for a request count

object - contains the field updated by the updater

n - the number of requests to add to the requested count

Returns:

requested value just prior to successful addition

getAndAddRequest

public static long getAndAddRequest(AtomicLong requested,
                                    long n)

Adds n to requested and returns the value prior to addition once the addition is successful (uses CAS semantics). If overflows then sets requested field to Long.MAX_VALUE.

Parameters:

requested - atomic field updater for a request count

n - the number of requests to add to the requested count

Returns:

requested value just prior to successful addition