Uses of Class
com.gigaspaces.internal.utils.concurrent.AsyncCallable
Packages that use AsyncCallable
Package
Description
-
Uses of AsyncCallable in com.gigaspaces.internal.client.cache
Subclasses of AsyncCallable in com.gigaspaces.internal.client.cache -
Uses of AsyncCallable in com.gigaspaces.internal.cluster.node.impl.groups.async
Subclasses of AsyncCallable in com.gigaspaces.internal.cluster.node.impl.groups.asyncModifier and TypeClassDescriptionclassThe async channel is in two states: 1) Idle (the async dispatcher has returned an IDLE_CONTINUE result) 2) Sending: 2.1) The async dispatcher is running (the call method is being executed), it is preparing the the packets for sending, and then dispatch them to the target in asynchronous manner 2.2) The async dispatcher is suspended, waiting to be resumed or waken once the async result is recieved and processed 2.3) onResult is called when the async result is arrived and the result is being processed which in its turn decide whether to go into idle mode or to continue to another sending cycle if there are enough packets pendingclass -
Uses of AsyncCallable in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync
Modifier and TypeClassDescriptionclass -
Uses of AsyncCallable in com.gigaspaces.internal.cluster.node.impl.groups.sync
Subclasses of AsyncCallable in com.gigaspaces.internal.cluster.node.impl.groups.sync -
Uses of AsyncCallable in com.gigaspaces.internal.cluster.node.impl.replica
Subclasses of AsyncCallable in com.gigaspaces.internal.cluster.node.impl.replicaModifier and TypeClassDescriptionclassRetrieve space copy replica data, can have multiple instances of this class running concurrently to retrieve the replica data -
Uses of AsyncCallable in com.gigaspaces.internal.utils.concurrent
Subclasses of AsyncCallable in com.gigaspaces.internal.utils.concurrentMethods in com.gigaspaces.internal.utils.concurrent with parameters of type AsyncCallableModifier and TypeMethodDescriptionAbstractAsyncHandlerProvider.start(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart) IAsyncHandlerProvider.start(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart) Start executing a runnable in a repetitive manner.protected abstract IAsyncHandlerAbstractAsyncHandlerProvider.startImpl(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart) ScheduledThreadPoolAsyncHandlerProvider.startImpl(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart) SharedHandlerProviderCache.SharedAsyncHandlerProviderWrapper.startImpl(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart) ThreadAsyncHandlerProvider.startImpl(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart) AbstractAsyncHandlerProvider.startMayBlock(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart) IAsyncHandlerProvider.startMayBlock(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart) Start executing a runnable in a repetitive manner, the task may block during its process so the provider must be able to support this.protected abstract IAsyncHandlerAbstractAsyncHandlerProvider.startMayBlockImpl(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart) ScheduledThreadPoolAsyncHandlerProvider.startMayBlockImpl(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart) SharedHandlerProviderCache.SharedAsyncHandlerProviderWrapper.startMayBlockImpl(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart) ThreadAsyncHandlerProvider.startMayBlockImpl(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart)