public class SharedBlockingCallback extends Object
void someBlockingCall(Object... args) throws IOException
{
try(Blocker blocker=sharedBlockingCallback.acquire())
{
someAsyncCall(args,blocker);
blocker.block();
}
}
| Modifier and Type | Class and Description |
|---|---|
class |
SharedBlockingCallback.Blocker
A Closeable Callback.
|
| Constructor and Description |
|---|
SharedBlockingCallback() |
| Modifier and Type | Method and Description |
|---|---|
SharedBlockingCallback.Blocker |
acquire() |
protected long |
getIdleTimeout() |
protected void |
notComplete(SharedBlockingCallback.Blocker blocker) |
protected long getIdleTimeout()
public SharedBlockingCallback.Blocker acquire() throws IOException
IOExceptionprotected void notComplete(SharedBlockingCallback.Blocker blocker)
Copyright © 1995-2015 Webtide. All Rights Reserved.