| Package | Description |
|---|---|
| io.vertx.camel | |
| io.vertx.core | |
| io.vertx.reactivex | |
| io.vertx.reactivex.core | |
| io.vertx.rx.java | |
| io.vertx.rxjava.core | |
| io.vertx.rxjava3 | |
| io.vertx.rxjava3.core |
| Modifier and Type | Method and Description |
|---|---|
WorkerExecutor |
OutboundMapping.getWorkerExecutor() |
| Modifier and Type | Method and Description |
|---|---|
OutboundMapping |
OutboundMapping.setWorkerExecutor(WorkerExecutor pool)
Sets the worker thread worker used to execute the blocking processing.
|
| Modifier and Type | Method and Description |
|---|---|
WorkerExecutor |
Vertx.createSharedWorkerExecutor(String name)
Like
Vertx.createSharedWorkerExecutor(String, int) but with the VertxOptions.setWorkerPoolSize(int) poolSize. |
WorkerExecutor |
Vertx.createSharedWorkerExecutor(String name,
int poolSize)
Like
Vertx.createSharedWorkerExecutor(String, int, long) but with the VertxOptions.setMaxWorkerExecuteTime(long) maxExecuteTime. |
WorkerExecutor |
Vertx.createSharedWorkerExecutor(String name,
int poolSize,
long maxExecuteTime)
Like
Vertx.createSharedWorkerExecutor(String, int, long, TimeUnit) but with the VertxOptions.setMaxWorkerExecuteTimeUnit(TimeUnit) maxExecuteTimeUnit. |
WorkerExecutor |
Vertx.createSharedWorkerExecutor(String name,
int poolSize,
long maxExecuteTime,
TimeUnit maxExecuteTimeUnit)
Create a named worker executor, the executor should be closed when it's not needed anymore to release
resources.
This method can be called mutiple times with the same
name. |
| Modifier and Type | Method and Description |
|---|---|
static Scheduler |
RxHelper.blockingScheduler(WorkerExecutor executor)
Create a scheduler for a
WorkerExecutor object, actions are executed on the threads of this executor. |
| Constructor and Description |
|---|
ContextScheduler(WorkerExecutor workerExecutor) |
ContextScheduler(WorkerExecutor workerExecutor,
boolean ordered) |
| Modifier and Type | Method and Description |
|---|---|
WorkerExecutor |
WorkerExecutor.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static WorkerExecutor |
WorkerExecutor.newInstance(WorkerExecutor arg) |
| Constructor and Description |
|---|
WorkerExecutor(WorkerExecutor delegate) |
| Constructor and Description |
|---|
ContextScheduler(WorkerExecutor workerExecutor) |
ContextScheduler(WorkerExecutor workerExecutor,
boolean ordered) |
| Modifier and Type | Method and Description |
|---|---|
WorkerExecutor |
WorkerExecutor.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static WorkerExecutor |
WorkerExecutor.newInstance(WorkerExecutor arg) |
| Constructor and Description |
|---|
WorkerExecutor(WorkerExecutor delegate) |
| Modifier and Type | Method and Description |
|---|---|
static Scheduler |
RxHelper.blockingScheduler(WorkerExecutor executor)
Create a scheduler for a
WorkerExecutor object, actions are executed on the threads of this executor. |
| Constructor and Description |
|---|
ContextScheduler(WorkerExecutor workerExecutor) |
ContextScheduler(WorkerExecutor workerExecutor,
boolean ordered) |
| Modifier and Type | Method and Description |
|---|---|
WorkerExecutor |
WorkerExecutor.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static WorkerExecutor |
WorkerExecutor.newInstance(WorkerExecutor arg) |
| Constructor and Description |
|---|
WorkerExecutor(WorkerExecutor delegate) |
Copyright © 2022 Eclipse. All rights reserved.