| Package | Description |
|---|---|
| com.liferay.portal.kernel.cluster | |
| com.liferay.portal.kernel.concurrent | |
| com.liferay.portal.kernel.process | |
| com.liferay.portal.kernel.process.local |
| 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) |
<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 |
|---|---|
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) |