Package io.deephaven.engine.updategraph

Class UpdateCommitter<T>

java.lang.Object

io.deephaven.engine.updategraph.AbstractNotification

io.deephaven.engine.updategraph.TerminalNotification

io.deephaven.engine.updategraph.UpdateCommitter<T>

All Implemented Interfaces:

LogOutputAppendable, NotificationQueue.Notification, IntrusiveDoublyLinkedNode<NotificationQueue.Notification>, Runnable

public class UpdateCommitter<T>
extends TerminalNotification

Tool for allowing cleanup at update cycle end as a TerminalNotification. The general pattern is to specify target as something that contains the state to be cleaned up, and invoke an instance method on target from committer. By maintaining only weak reachability to target, we avoid prolonging its lifetime in order to perform cleanup tasks that would be obviated by its collection.

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.util.datastructures.linked.IntrusiveDoublyLinkedNode

IntrusiveDoublyLinkedNode.Adapter<NODE_TYPE extends IntrusiveDoublyLinkedNode<NODE_TYPE>>, IntrusiveDoublyLinkedNode.Impl<NODE_TYPE extends IntrusiveDoublyLinkedNode.Impl<NODE_TYPE>>

Constructor Summary

Constructors

Constructor	Description
UpdateCommitter(T target, UpdateGraph updateGraph, Consumer<T> committer)

Method Summary

Modifier and Type	Method	Description
void	maybeActivate()
void	run()

Methods inherited from class io.deephaven.engine.updategraph.TerminalNotification

canExecute

Methods inherited from class io.deephaven.engine.updategraph.AbstractNotification

append, getNext, getPrev, isTerminal, mustExecuteWithUpdateGraphLock, setNext, setPrev, toString

Methods inherited from class java.lang.Object

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

Constructor Details

UpdateCommitter

public UpdateCommitter(T target,
 UpdateGraph updateGraph,
 Consumer<T> committer)

Method Details

run

public void run()

maybeActivate

public void maybeActivate()