Package com.helix.core.executor

Class AsyncExecutor

java.lang.Object

com.helix.core.executor.AsyncExecutor

All Implemented Interfaces:

AutoCloseable

public class AsyncExecutor
extends Object
implements AutoCloseable

Asynchronous rule executor using CompletableFuture backed by a configurable ThreadPoolExecutor.

Constructor Summary

Constructors

Constructor	Description
AsyncExecutor()
AsyncExecutor(ExecutorConfiguration config)
AsyncExecutor(SyncExecutor syncExecutor, ExecutorService executorService)

Method Summary

Modifier and Type	Method	Description
void	close()
CompletableFuture<ExecutionResult>	executeAsync(CompiledRule compiledRule, ExecutionContext context)
CompletableFuture<ExecutionResult>	executeAsync(CompiledRule compiledRule, ExecutionContext context, long timeout, TimeUnit unit)
ExecutorService	getExecutorService()
ExecutorMetrics	getMetrics()

Methods inherited from class java.lang.Object

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

Constructor Details

AsyncExecutor

public AsyncExecutor()

AsyncExecutor

public AsyncExecutor(ExecutorConfiguration config)

AsyncExecutor

public AsyncExecutor(SyncExecutor syncExecutor,
 ExecutorService executorService)

Method Details

executeAsync

public CompletableFuture<ExecutionResult> executeAsync(CompiledRule compiledRule,
 ExecutionContext context)

executeAsync

public CompletableFuture<ExecutionResult> executeAsync(CompiledRule compiledRule,
 ExecutionContext context,
 long timeout,
 TimeUnit unit)

getMetrics

public ExecutorMetrics getMetrics()

getExecutorService

public ExecutorService getExecutorService()

close

public void close()

Specified by:

close in interface AutoCloseable