org.fusesource.hawtdispatch

Class AggregatingExecutor

java.lang.Object

org.fusesource.hawtdispatch.AggregatingExecutor

All Implemented Interfaces:

java.util.concurrent.Executor

public class AggregatingExecutor
extends java.lang.Object
implements java.util.concurrent.Executor

Sends runnable tasks to a DispatchQueue via a an EventAggregator so that they first batch up on the sender side before being sent to the DispatchQueue which then executes that tasks.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) DispatchQueue	queue
(package private) CustomDispatchSource<java.lang.Runnable,java.util.LinkedList<java.lang.Runnable>>	source

Constructor Summary

Constructors

Constructor and Description
AggregatingExecutor(DispatchQueue queue)

Method Summary

Modifier and Type	Method and Description
void	execute(java.lang.Runnable task)
void	resume()
void	suspend()

Methods inherited from class java.lang.Object

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

Field Detail

queue

final DispatchQueue queue

source

final CustomDispatchSource<java.lang.Runnable,java.util.LinkedList<java.lang.Runnable>> source

Constructor Detail

AggregatingExecutor

public AggregatingExecutor(DispatchQueue queue)

Method Detail

suspend

public void suspend()

resume

public void resume()

execute

public void execute(java.lang.Runnable task)

Specified by:

execute in interface java.util.concurrent.Executor