Package org.apache.polaris.nosql.async.vertx

Class VertxAsyncExec

java.lang.Object

org.apache.polaris.nosql.async.vertx.VertxAsyncExec

All Implemented Interfaces:

AutoCloseable, org.apache.polaris.nosql.async.AsyncExec

@ApplicationScoped
class VertxAsyncExec
extends Object
implements org.apache.polaris.nosql.async.AsyncExec, AutoCloseable

CDI ApplicationScoped AsyncExec implementation that uses Vert.X timers, backed by a Java thread pool to execute blocking tasks.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EXECUTOR_THREAD_NAME_PREFIX

Constructor Summary

Constructors

Constructor	Description
VertxAsyncExec(io.vertx.core.Vertx vertx, org.apache.polaris.nosql.async.AsyncConfiguration asyncConfiguration)

Method Summary

Modifier and Type	Method	Description
void	close()
<R> org.apache.polaris.nosql.async.Cancelable<R>	schedule(Callable<R> callable, Duration delay)
org.apache.polaris.nosql.async.Cancelable<Void>	schedulePeriodic(Runnable runnable, Duration initialDelay, Duration delay)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.polaris.nosql.async.AsyncExec

schedule, schedulePeriodic, submit

Field Details

EXECUTOR_THREAD_NAME_PREFIX

public static final String EXECUTOR_THREAD_NAME_PREFIX

See Also:

• Constant Field Values

Constructor Details

VertxAsyncExec

@Inject
VertxAsyncExec(io.vertx.core.Vertx vertx,
 org.apache.polaris.nosql.async.AsyncConfiguration asyncConfiguration)

Method Details

close

@PreDestroy
public void close()

Specified by:

close in interface AutoCloseable

schedule

public <R>
org.apache.polaris.nosql.async.Cancelable<R> schedule(Callable<R> callable,
 Duration delay)

Specified by:

schedule in interface org.apache.polaris.nosql.async.AsyncExec

schedulePeriodic

public org.apache.polaris.nosql.async.Cancelable<Void> schedulePeriodic(Runnable runnable,
 Duration initialDelay,
 Duration delay)

Specified by:

schedulePeriodic in interface org.apache.polaris.nosql.async.AsyncExec

toString

public String toString()

Overrides:

toString in class Object