Modifier and Type | Field and Description |
---|---|
private static final long | dgcAckTimeout
timeout for holding references without receiving an acknowledgment |
private final UID | |
private static final Map | idTable
table mapping ack ID to handler |
private List | |
private static final ScheduledExecutorService | scheduler
thread pool for scheduling delayed tasks |
private Future |
Access | Constructor and Description |
---|---|
pack-priv | DGCAckHandler(UID id)
Creates a new DGCAckHandler, associated with the specified UID if the argument is not null. |
Modifier and Type | Method and Description |
---|---|
pack-priv synchronized void | |
public static void | |
pack-priv synchronized void | |
pack-priv synchronized void |
dgcAckTimeout | back to summary |
---|---|
private static final long dgcAckTimeout timeout for holding references without receiving an acknowledgment
|
id | back to summary |
---|---|
private final UID id |
idTable | back to summary |
---|---|
private static final Map<UID, DGCAckHandler> idTable table mapping ack ID to handler |
objList | back to summary |
---|---|
private List<Object> objList |
scheduler | back to summary |
---|---|
private static final ScheduledExecutorService scheduler thread pool for scheduling delayed tasks
|
task | back to summary |
---|---|
private Future<?> task |
DGCAckHandler | back to summary |
---|---|
pack-priv DGCAckHandler(UID id) Creates a new DGCAckHandler, associated with the specified UID if the argument is not null. References added to this DGCAckHandler will be held strongly until its "release" method is invoked or (after the "startTimer" method has been invoked) the timeout has expired. If the argument is not null, then invoking the static "received" method with the specified UID is equivalent to invoking this instance's "release" method. |
add | back to summary |
---|---|
pack-priv synchronized void add(Object obj) Adds the specified reference to this DGCAckHandler. |
received | back to summary |
---|---|
public static void received(UID id) Causes the DGCAckHandler associated with the specified UID to release its references. |
release | back to summary |
---|---|
pack-priv synchronized void release() Releases the references held by this DGCAckHandler. |
startTimer | back to summary |
---|---|
pack-priv synchronized void startTimer() Starts the timer for this DGCAckHandler. After the timeout has expired, the references are released even if the acknowledgment has not been received. |