com.facebook.buck.event.listener

Class BuckEventOrderer<T extends BuckEvent>

java.lang.Object

com.facebook.buck.event.listener.BuckEventOrderer<T>

All Implemented Interfaces:

AutoCloseable

public class BuckEventOrderer<T extends BuckEvent>
extends Object
implements AutoCloseable

Orders BuckEvents by the BuckEvent.getNanoTime() value. This is used to serialize events coming in from multiple threads.

Constructor Summary

Constructors

Constructor and Description
BuckEventOrderer(java.util.function.Consumer<T> eventSinkFunction, long maximumSkew, TimeUnit maximumSkewUnit)

Method Summary

Modifier and Type	Method and Description
void	add(T buckEvent)
void	close()

Methods inherited from class java.lang.Object

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

Constructor Detail

BuckEventOrderer

public BuckEventOrderer(java.util.function.Consumer<T> eventSinkFunction,
                        long maximumSkew,
                        TimeUnit maximumSkewUnit)

Parameters:

eventSinkFunction - events for which we've determined ordering are dispatched here.

maximumSkew - this is how many events

Method Detail

add

public void add(T buckEvent)

close

public void close()

Specified by:

close in interface AutoCloseable