org.apache.storm.daemon.supervisor

Class OnlyLatestExecutor<K>

java.lang.Object

org.apache.storm.daemon.supervisor.OnlyLatestExecutor<K>

public class OnlyLatestExecutor<K>
extends Object

This allows you to submit a Runnable with a key. If the previous submission for that key has not yet run, it will be replaced with the latest one.

Constructor Summary

Constructors

Constructor and Description
OnlyLatestExecutor(Executor exec)

Method Summary

Modifier and Type	Method and Description
void	execute(K key, Runnable r) Run something in the future, but replace it with the latest if it is taking too long

Methods inherited from class java.lang.Object

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

Constructor Detail

OnlyLatestExecutor

public OnlyLatestExecutor(Executor exec)

Method Detail

execute

public void execute(K key,
                    Runnable r)

Run something in the future, but replace it with the latest if it is taking too long

Parameters:

key - what to use to dedupe things.

r - what you want to run.