org.apache.pulsar.common.util.collections

Class ConcurrentLongPairSet

java.lang.Object

org.apache.pulsar.common.util.collections.ConcurrentLongPairSet

public class ConcurrentLongPairSet
extends Object

Concurrent hash set where values are composed of pairs of longs.

(long,long)

Provides similar methods as a ConcurrentHashSet but since it's an open hash set with linear probing, no node allocations are required to store the keys and values, and no boxing is required.

Values MUST be >= 0.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ConcurrentLongPairSet.ConsumerLong
static class	ConcurrentLongPairSet.LongPair
static interface	ConcurrentLongPairSet.LongPairConsumer
static interface	ConcurrentLongPairSet.LongPairPredicate

Constructor Summary

Constructors

Constructor and Description
ConcurrentLongPairSet()
ConcurrentLongPairSet(int expectedItems)
ConcurrentLongPairSet(int expectedItems, int concurrencyLevel)

Method Summary

Modifier and Type	Method and Description
boolean	add(long item1, long item2)
long	capacity()
void	clear()
boolean	contains(long item1, long item2)
void	forEach(ConcurrentLongPairSet.LongPairConsumer processor)
boolean	isEmpty()
Set<ConcurrentLongPairSet.LongPair>	items()
Set<ConcurrentLongPairSet.LongPair>	items(int numberOfItems)
boolean	remove(long item1, long item2) Remove an existing entry if found
int	removeIf(ConcurrentLongPairSet.LongPairPredicate filter) Removes all of the elements of this collection that satisfy the given predicate.
long	size()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConcurrentLongPairSet

public ConcurrentLongPairSet()

ConcurrentLongPairSet

public ConcurrentLongPairSet(int expectedItems)

ConcurrentLongPairSet

public ConcurrentLongPairSet(int expectedItems,
                             int concurrencyLevel)

Method Detail

size

public long size()

capacity

public long capacity()

isEmpty

public boolean isEmpty()

contains

public boolean contains(long item1,
                        long item2)

add

public boolean add(long item1,
                   long item2)

remove

public boolean remove(long item1,
                      long item2)

Remove an existing entry if found

Parameters:

item1 -

Returns:

true if removed or false if item was not present

clear

public void clear()

forEach

public void forEach(ConcurrentLongPairSet.LongPairConsumer processor)

removeIf

public int removeIf(ConcurrentLongPairSet.LongPairPredicate filter)

Removes all of the elements of this collection that satisfy the given predicate.

Parameters:

filter - a predicate which returns true for elements to be removed

Returns:

true if any elements were removed

items

public Set<ConcurrentLongPairSet.LongPair> items()

Returns:

a new list of all keys (makes a copy)

items

public Set<ConcurrentLongPairSet.LongPair> items(int numberOfItems)

Returns:

a new list of keys with max provided numberOfItems (makes a copy)

toString

public String toString()

Overrides:

toString in class Object