| Constructor and Description |
|---|
SpaceInterceptor(Space<K,V> sp) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
existAny(K[] keys) |
boolean |
existAny(K[] keys,
long timeout) |
V |
in(K key)
Take an entry from the space, waiting forever until one exists.
|
V |
in(K key,
long timeout)
Take an entry from the space, waiting a limited amount of time
until one exists.
|
V |
inp(K key)
In probe takes an entry from the space if one exists,
return null otherwise.
|
void |
nrd(K key)
Nrd (not read) waits forever until Key is not present in space
Resolution for expiring entries is implementation dependant, but a minimum one-second is suggested.
|
V |
nrd(K key,
long timeout)
Nrd (not read) waits up to timeout until Key is not present in space
Resolution for expiring entries is implementation dependant, but a minimum one-second is suggested.
|
void |
out(K key,
V value)
Write a new entry into the Space
|
void |
out(K key,
V value,
long timeout)
Write a new entry into the Space, with an timeout value
|
void |
push(K key,
V value)
Write a new entry at the head of a queue.
|
void |
push(K key,
V value,
long timeout)
Write a new entry at the head of the queue with a timeout value
|
void |
put(K key,
V value)
Write a single entry at the head of the queue discarding the other entries
|
void |
put(K key,
V value,
long timeout)
Write a single entry at the head of the queue discarding the other entries, with timeout.
|
V |
rd(K key)
Read an entry from the space, waiting forever until one exists.
|
V |
rd(K key,
long timeout)
Read an entry from the space, waiting a limited amount of time
until one exists.
|
V |
rdp(K key)
Read probe reads an entry from the space if one exists,
return null otherwise.
|
public void out(K key, V value)
Spacepublic void out(K key, V value, long timeout)
Spacepublic void push(K key, V value)
Spacepublic void push(K key, V value, long timeout)
Spacepublic void put(K key, V value)
Spacepublic void put(K key, V value, long timeout)
Spacepublic V in(K key)
Spacepublic V rd(K key)
Spacepublic V in(K key, long timeout)
Spacepublic V rd(K key, long timeout)
Spacepublic V inp(K key)
Spacepublic V rdp(K key)
Spacepublic void nrd(K key)
Spacepublic V nrd(K key, long timeout)
Spacepublic boolean existAny(K[] keys)