diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2012-11-08 13:20:47 +0100 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2012-11-08 13:20:47 +0100 |
commit | d6a532c420a93b211a9747c5fb807a3f2767fa22 (patch) | |
tree | 572bc13c87a726cbc7132043cc1d10af795f442b /src/main/java/io/trygvis/esper/testing/ResourceManager.java | |
parent | ff34cdc13bc8ba0943cded8009b9869a455894f6 (diff) | |
download | esper-testing-d6a532c420a93b211a9747c5fb807a3f2767fa22.tar.gz esper-testing-d6a532c420a93b211a9747c5fb807a3f2767fa22.tar.bz2 esper-testing-d6a532c420a93b211a9747c5fb807a3f2767fa22.tar.xz esper-testing-d6a532c420a93b211a9747c5fb807a3f2767fa22.zip |
o Slurping down the entire list of projects.
Diffstat (limited to 'src/main/java/io/trygvis/esper/testing/ResourceManager.java')
-rw-r--r-- | src/main/java/io/trygvis/esper/testing/ResourceManager.java | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/src/main/java/io/trygvis/esper/testing/ResourceManager.java b/src/main/java/io/trygvis/esper/testing/ResourceManager.java new file mode 100644 index 0000000..e9a0068 --- /dev/null +++ b/src/main/java/io/trygvis/esper/testing/ResourceManager.java @@ -0,0 +1,31 @@ +package io.trygvis.esper.testing; + +import fj.*; + +import java.util.*; +import java.util.concurrent.*; + +public class ResourceManager<K, V> { + private final Equal<K> equal; + private final Callable<List<K>> discoverer; + private Map<K, V> map = Collections.emptyMap(); + + public ResourceManager(Equal<K> equal, ScheduledExecutorService executorService, int delay, Callable<List<K>> discoverer) { + this.equal = equal; + this.discoverer = discoverer; + + executorService.scheduleWithFixedDelay(new Runnable() { + public void run() { + work(); + } + }, delay, delay, TimeUnit.MILLISECONDS); + } + + private void work() { + try { + List<K> keys = discoverer.call(); + } catch (Exception e) { + return; + } + } +} |