Package | Description |
---|---|
org.infinispan.executors |
Implementations of different executors used for asynchronous operation.
|
org.infinispan.remoting.inboundhandler | |
org.infinispan.util.concurrent |
Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities
and containers.
|
Modifier and Type | Method and Description |
---|---|
void |
LazyInitializingBlockingTaskAwareExecutorService.execute(BlockingRunnable runnable) |
Modifier and Type | Class and Description |
---|---|
class |
BaseBlockingRunnable
Common logic to handle
CacheRpcCommand . |
class |
DefaultTopologyRunnable
The default
Runnable for the remote commands receives. |
Modifier and Type | Method and Description |
---|---|
protected BlockingRunnable |
BasePerCacheInboundInvocationHandler.createDefaultRunnable(CacheRpcCommand command,
Reply reply,
int commandTopologyId,
boolean waitTransactionalData,
boolean onExecutorService) |
protected BlockingRunnable |
NonTotalOrderTxPerCacheInboundInvocationHandler.createReadyActionRunnable(CacheRpcCommand command,
Reply reply,
int commandTopologyId,
boolean waitTransactionalData,
boolean onExecutorService,
ReadyAction readyAction) |
Modifier and Type | Method and Description |
---|---|
protected void |
BasePerCacheInboundInvocationHandler.handleRunnable(BlockingRunnable runnable,
boolean onExecutorService) |
Modifier and Type | Method and Description |
---|---|
void |
BlockingTaskAwareExecutorService.execute(BlockingRunnable runnable)
Executes the given command at some time in the future when the command is less probably to block a thread.
|
void |
BlockingTaskAwareExecutorServiceImpl.execute(BlockingRunnable runnable) |
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.