public Class CombinerExecutor<S>

Lock free executor. When a thread submits an action, it will enqueue the action to execute and then try to acquire a lock. When the lock is acquired it will execute all the tasks in the queue until empty and then release the lock.

Nested and Inner Type Summary

Modifier and Type	Class and Description
protected static class	CombinerExecutor.InProgressTail<S>

Field Summary

Modifier and Type	Field and Description
private static final FastThreadLocal<CombinerExecutor.InProgressTail<?>>	current
private final Queue<Executor.Action<S>>	q
private final AtomicInteger	s
private final S	state

Constructor Summary

Access	Constructor and Description
public	CombinerExecutor(S state)

Method Summary

Modifier and Type	Method and Description
public void	submit(Executor.Action<S> the action action) Implements io.vertx.core.net.impl.pool.Executor.submit. Submit an action.

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

Field Detail

current	back to summary
private static final FastThreadLocal<CombinerExecutor.InProgressTail<?>> current

q	back to summary
private final Queue<Executor.Action<S>> q

s	back to summary
private final AtomicInteger s

state	back to summary
private final S state

Constructor Detail

CombinerExecutor	back to summary
public CombinerExecutor(S state)

Method Detail

submit	back to summary
public void submit(Executor.Action<S> action) Implements io.vertx.core.net.impl.pool.Executor.submit. Doc from io.vertx.core.net.impl.pool.Executor.submit. Submit an action. Parameters action:Executor.Action<S> the action Annotations @Override

submit

back to summary

public void submit(Executor.Action<S> action)

Implements io.vertx.core.net.impl.pool.Executor.submit.

Doc from io.vertx.core.net.impl.pool.Executor.submit.

Submit an action.

Parameters

action:Executor.Action<S>: the action

Annotations

@Override

io.vertx.core.net.impl.pool back to summary

protected final Class CombinerExecutor.InProgressTail<S>

Class Inheritance

extends Object

java.lang.Object
io.vertx.core.net.impl.pool.CombinerExecutor.InProgressTail

Field Summary

Modifier and Type	Field and Description
pack-priv final CombinerExecutor<S>	combiner
pack-priv Map<CombinerExecutor<S>, Task>	others
pack-priv Task	task

Constructor Summary

Access	Constructor and Description
public	InProgressTail(CombinerExecutor<S> combiner, Task task)

Method Summary

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

Field Detail

combiner	back to summary
pack-priv final CombinerExecutor<S> combiner

others	back to summary
pack-priv Map<CombinerExecutor<S>, Task> others

task	back to summary
pack-priv Task task

Constructor Detail

InProgressTail	back to summary
public InProgressTail(CombinerExecutor<S> combiner, Task task)