com.gigaspaces.internal.utils.concurrent

Class CompetitionExecutor<T extends CompetitiveTask>

java.lang.Object

com.gigaspaces.internal.utils.concurrent.CompetitionExecutor<T>

All Implemented Interfaces:

IAsyncHandlerProviderStateListener

Direct Known Subclasses:

RepeatsCompetitionExecutor, TimedCompetitionExecutor

public abstract class CompetitionExecutor<T extends CompetitiveTask>
extends Object
implements IAsyncHandlerProviderStateListener

Since:

9.0.1

Author:

Niv Ingberg

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	CompetitionExecutor.CompetitorWrapper

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CompetitionExecutor(IAsyncHandlerProvider asyncHandlerProvider)

Method Summary

Modifier and Type	Method and Description
T	await(long timeout, TimeUnit unit)
boolean	isCompleted()
void	onClosed() Called when the IAsyncHandlerProvider is closed
protected void	start(T[] competitors, long idleDelay, String name)
protected abstract CompetitionExecutor.CompetitorWrapper	wrapCompetitor(T competitor)

Methods inherited from class java.lang.Object

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

Constructor Detail

CompetitionExecutor

protected CompetitionExecutor(IAsyncHandlerProvider asyncHandlerProvider)

Method Detail

start

protected void start(T[] competitors,
                     long idleDelay,
                     String name)

wrapCompetitor

protected abstract CompetitionExecutor.CompetitorWrapper wrapCompetitor(T competitor)

onClosed

public void onClosed()

Description copied from interface: IAsyncHandlerProviderStateListener

Called when the IAsyncHandlerProvider is closed

Specified by:

onClosed in interface IAsyncHandlerProviderStateListener

isCompleted

public boolean isCompleted()

await

public T await(long timeout,
               TimeUnit unit)
        throws InterruptedException,
               ExecutionException

Throws:

InterruptedException

ExecutionException