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
IOException
protected void notComplete(SharedBlockingCallback.Blocker blocker)
Copyright © 1995-2015 Webtide. All Rights Reserved.