com.gigaspaces.internal.utils.concurrent

Class ThreadAsyncHandlerProvider

java.lang.Object

com.gigaspaces.internal.utils.concurrent.AbstractAsyncHandlerProvider

com.gigaspaces.internal.utils.concurrent.ThreadAsyncHandlerProvider

All Implemented Interfaces:

IAsyncHandlerProvider

public class ThreadAsyncHandlerProvider
extends AbstractAsyncHandlerProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ThreadAsyncHandlerProvider.AsyncRunnableWrapper

Nested classes/interfaces inherited from class com.gigaspaces.internal.utils.concurrent.AbstractAsyncHandlerProvider

AbstractAsyncHandlerProvider.ClosedProviderAsyncHandler

Nested classes/interfaces inherited from interface com.gigaspaces.internal.utils.concurrent.IAsyncHandlerProvider

IAsyncHandlerProvider.CycleResult

Field Summary

Fields inherited from class com.gigaspaces.internal.utils.concurrent.AbstractAsyncHandlerProvider

_stateLock

Constructor Summary

Constructors

Constructor and Description
ThreadAsyncHandlerProvider()

Method Summary

Modifier and Type	Method and Description
int	activeThreadsCount()
protected void	onClose()
void	removeCurrent()
IAsyncHandler	startImpl(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart)
IAsyncHandler	startMayBlockImpl(AsyncCallable callable, long idleDelayMilis, String name, boolean waitIdleDelayBeforeStart)

Methods inherited from class com.gigaspaces.internal.utils.concurrent.AbstractAsyncHandlerProvider

addStateListener, close, isClosed, removeStateListener, start, startMayBlock

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ThreadAsyncHandlerProvider

public ThreadAsyncHandlerProvider()

Method Detail

startImpl

public IAsyncHandler startImpl(AsyncCallable callable,
                               long idleDelayMilis,
                               String name,
                               boolean waitIdleDelayBeforeStart)

Specified by:

startImpl in class AbstractAsyncHandlerProvider

startMayBlockImpl

public IAsyncHandler startMayBlockImpl(AsyncCallable callable,
                                       long idleDelayMilis,
                                       String name,
                                       boolean waitIdleDelayBeforeStart)

Specified by:

startMayBlockImpl in class AbstractAsyncHandlerProvider

removeCurrent

public void removeCurrent()

onClose

protected void onClose()

Specified by:

onClose in class AbstractAsyncHandlerProvider

activeThreadsCount

public int activeThreadsCount()