Modifier and Type	Class and Description
public static interface	WorkerExecutor.Continuation

Modifier and Type	Field and Description
private final ThreadLocal<Boolean>	inThread
private final WorkerTaskQueue	orderedTasks
private final WorkerPool	workerPool

Access	Constructor and Description
public	WorkerExecutor(WorkerPool workerPool, WorkerTaskQueue orderedTasks)

Method Summary

Modifier and Type	Method and Description
public void	execute(Runnable the runnable task command) Implements java.util.concurrent.Executor.execute. Executes the given command at some time in the future.
public boolean	inThread() Implements io.vertx.core.impl.EventExecutor.inThread.
public CountDownLatch	Returns: the latch to wait for until the current task can resume suspend(Consumer<WorkerExecutor.Continuation> resumeAcceptor) Suspend the current task execution until the task is resumed, the next task in the queue will be executed when there is one.
pack-priv WorkerTaskQueue	taskQueue()
public static WorkerExecutor	unwrapWorkerExecutor()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

inThread	back to summary
private final ThreadLocal<Boolean> inThread

orderedTasks	back to summary
private final WorkerTaskQueue orderedTasks

workerPool	back to summary
private final WorkerPool workerPool

Constructor Detail

WorkerExecutor	back to summary
public WorkerExecutor(WorkerPool workerPool, WorkerTaskQueue orderedTasks)

Method Detail

execute back to summary

execute	back to summary
public void execute(Runnable command) Implements java.util.concurrent.Executor.execute. Doc from java.util.concurrent.Executor.execute. Executes the given command at some time in the future. The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the `Executor` implementation. Parameters command:Runnable the runnable task Annotations @Override

public void execute(Runnable command)

Implements java.util.concurrent.Executor.execute.

Doc from java.util.concurrent.Executor.execute.

Executes the given command at some time in the future. The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the Executor implementation.

Parameters

command:Runnable: the runnable task

Annotations

@Override

inThread	back to summary
public boolean inThread() Implements io.vertx.core.impl.EventExecutor.inThread. Returns:boolean Doc from io.vertx.core.impl.EventExecutor.inThread. whether the current thread is one of the event executor thread Annotations @Override

inThread

back to summary

public boolean inThread()

Implements io.vertx.core.impl.EventExecutor.inThread.

Returns:boolean

Doc from io.vertx.core.impl.EventExecutor.inThread.

whether the current thread is one of the event executor thread

Annotations

@Override

suspend back to summary

suspend	back to summary
public CountDownLatch suspend(Consumer<WorkerExecutor.Continuation> resumeAcceptor) Suspend the current task execution until the task is resumed, the next task in the queue will be executed when there is one. The `resumeAcceptor` argument is passed the continuation to resume the current task, this acceptor is guaranteed to be called before the task is actually suspended so the task can be eagerly resumed and avoid suspending the current task. Returns:CountDownLatch the latch to wait for until the current task can resume

public CountDownLatch suspend(Consumer<WorkerExecutor.Continuation> resumeAcceptor)

Suspend the current task execution until the task is resumed, the next task in the queue will be executed when there is one.

The resumeAcceptor argument is passed the continuation to resume the current task, this acceptor is guaranteed to be called before the task is actually suspended so the task can be eagerly resumed and avoid suspending the current task.

Returns:CountDownLatch: the latch to wait for until the current task can resume

taskQueue	back to summary
pack-priv WorkerTaskQueue taskQueue()

unwrapWorkerExecutor	back to summary
public static WorkerExecutor unwrapWorkerExecutor()

io.vertx.core.impl back to summary

public Interface WorkerExecutor.Continuation

Known Direct Implementers: io.vertx.core.impl.TaskQueue.ContinuationTask

Method Summary

Modifier and Type	Method and Description
public void	resume(Runnable called when the task is resumed callback) Resume the task, the `callback` will be executed when the task is resumed, before the task thread is un-parked.
public default void	resume() Like `resume(Runnable)`.

Method Detail

resume back to summary

resume	back to summary
public void resume(Runnable callback) Resume the task, the `callback` will be executed when the task is resumed, before the task thread is un-parked. Parameters callback:Runnable called when the task is resumed

public void resume(Runnable callback)

Resume the task, the callback will be executed when the task is resumed, before the task thread is un-parked.

Parameters

callback:Runnable: called when the task is resumed

resume	back to summary
public default void resume() Like `resume(Runnable)`.

public Class WorkerExecutor

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Interface WorkerExecutor.Continuation

Method Summary

Method Detail