Modifier and Type | Class and Description |
---|---|
class |
FutureClusterResponses |
Modifier and Type | Method and Description |
---|---|
<T> NoticeableFuture<T> |
ClusterMasterExecutor.executeOnMaster(MethodHandler methodHandler) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultNoticeableFuture<T> |
class |
NoticeableFutureConverter<T,V> |
Modifier and Type | Method and Description |
---|---|
NoticeableFuture<V> |
AsyncBroker.post(K key) |
NoticeableFuture<V> |
AsyncBroker.post(K key,
boolean[] newMarker) |
NoticeableFuture<V> |
AsyncBroker.post(K key,
DefaultNoticeableFuture<V> defaultNoticeableFuture)
Deprecated.
As of Judson (7.1.x), replaced by
AsyncBroker.post(Object,
boolean[]) |
<T> NoticeableFuture<T> |
ThreadPoolExecutor.submit(Callable<T> callable) |
NoticeableFuture<?> |
ThreadPoolExecutor.submit(Runnable runnable) |
<T> NoticeableFuture<T> |
ThreadPoolExecutor.submit(Runnable runnable,
T result) |
NoticeableFuture<V> |
AsyncBroker.take(K key) |
NoticeableFuture<Void> |
ThreadPoolExecutor.terminationNoticeableFuture() |
Modifier and Type | Method and Description |
---|---|
Map<K,NoticeableFuture<V>> |
AsyncBroker.getOpenBids() |
Constructor and Description |
---|
NoticeableFutureConverter(NoticeableFuture<V> noticeableFuture) |
Modifier and Type | Method and Description |
---|---|
static <V extends Serializable> |
IntrabandRPCUtil.execute(RegistrationReference registrationReference,
ProcessCallable<V> processCallable) |
Modifier and Type | Method and Description |
---|---|
static <O,E> NoticeableFuture<ObjectValuePair<O,E>> |
ProcessUtil.execute(OutputProcessor<O,E> outputProcessor,
List<String> arguments) |
static <O,E> NoticeableFuture<ObjectValuePair<O,E>> |
ProcessUtil.execute(OutputProcessor<O,E> outputProcessor,
String... arguments) |
NoticeableFuture<T> |
ProcessChannel.getProcessNoticeableFuture() |
<V extends Serializable> |
ProcessChannel.write(ProcessCallable<V> processCallable) |
Modifier and Type | Method and Description |
---|---|
NoticeableFuture<T> |
LocalProcessChannel.getProcessNoticeableFuture() |
<V extends Serializable> |
LocalProcessChannel.write(ProcessCallable<V> processCallable) |
Constructor and Description |
---|
LocalProcessChannel(NoticeableFuture<T> noticeableFuture,
ObjectOutputStream objectOutputStream,
AsyncBroker<Long,Serializable> asyncBroker) |