com.comphenix.protocol.concurrency

Class BlockingHashMap<TKey,TValue>

java.lang.Object

com.comphenix.protocol.concurrency.BlockingHashMap<TKey,TValue>

Type Parameters:

TKey - - type of the key.

TValue - - type of the value.

public class BlockingHashMap<TKey,TValue>
extends java.lang.Object

A map that supports blocking on read operations. Null keys are not supported.

Keys are stored as weak references, and will be automatically removed once they've all been dereferenced.

Author:

Kristian

Constructor Summary

Constructors

Constructor and Description
BlockingHashMap() Initialize a new map.

Method Summary

Methods

Modifier and Type	Method and Description
static <TKey,TValue> BlockingHashMap<TKey,TValue>	create() Initialize a new map.
TValue	get(TKey key) Waits until a value has been associated with the given key, and then retrieves that value.
TValue	get(TKey key, long timeout, java.util.concurrent.TimeUnit unit) Waits until a value has been associated with the given key, and then retrieves that value.
java.util.Set<TKey>	keys()
TValue	put(TKey key, TValue value) Associate a given key with the given value.
int	size()
java.util.Collection<TValue>	values()

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingHashMap

public BlockingHashMap()

Initialize a new map.

Method Detail

create

public static <TKey,TValue> BlockingHashMap<TKey,TValue> create()

Initialize a new map.

Returns:

The created map.

get

public TValue get(TKey key)
           throws java.lang.InterruptedException

Waits until a value has been associated with the given key, and then retrieves that value.

Parameters:

key - - the key whose associated value is to be returned

Returns:

The value to which the specified key is mapped.

Throws:

java.lang.InterruptedException - If the current thread got interrupted while waiting.

get

public TValue get(TKey key,
         long timeout,
         java.util.concurrent.TimeUnit unit)
           throws java.lang.InterruptedException

Waits until a value has been associated with the given key, and then retrieves that value.

Parameters:

key - - the key whose associated value is to be returned

timeout - - the amount of time to wait until an association has been made.

unit - - unit of timeout.

Returns:

The value to which the specified key is mapped, or NULL if the timeout elapsed.

Throws:

java.lang.InterruptedException - If the current thread got interrupted while waiting.

put

public TValue put(TKey key,
         TValue value)

Associate a given key with the given value.

Wakes up any blocking getters on this specific key.

Parameters:

key - - the key to associate.

value - - the value.

Returns:

The previously associated value.

size

public int size()

values

public java.util.Collection<TValue> values()

keys

public java.util.Set<TKey> keys()