Package com.gigaspaces.internal.utils.concurrent
package com.gigaspaces.internal.utils.concurrent
-
ClassDescriptionCompetitionExecutor<T extends CompetitiveTask>Base class for Callable implementations which should run in a specific class loader.Base class for Runnable implementations which should run in a specific class loader.Base thread that should be used all across GigaSpaces code.Thread factory to create
GSThread.Timer that should be used all across GigaSpaces code.Wraps a repetitive executing runnable which is provided to aIAsyncHandlerProvider.start(IAsyncCallable, long, String, boolean)invocation and controls its life cycle.ProvidesIAsyncHandlerfor repetitive execution of runnablesA simple lock implementation that supports only lock and unlockA non reentrant implementation ofISimpleLockThe implementation intent is to save memory, therefore the synchronization is done on the lock object it self, no user should synchronize on the lock object it self as it may create deadlocks.Reentrant implementation ofISimpleLockThe implementation intent is to save memory, therefore the synchronization is done on the lock object it self, no user should synchronize on the lock object it self as it may create deadlocks.RepeatsCompetitionExecutor<T extends CompetitiveTask>Decorates a runnable with the property that the execution of the runnable will be made with the specified class loaderScheduled thread pool based implementation forIAsyncHandlerProviderProvides a segmented counter while the get() returns an accurate result.A segmented implementation of ReentrantReadWriteLock, providing better concurrency.A cache to share async handler providers within the same context (service class loader/processing unit instance)TimedCompetitionExecutor<T extends CompetitiveTask>