aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/esper/testing/ResourceManager.java
diff options
context:
space:
mode:
authorTrygve Laugstøl <trygvis@inamo.no>2012-11-08 13:20:47 +0100
committerTrygve Laugstøl <trygvis@inamo.no>2012-11-08 13:20:47 +0100
commitd6a532c420a93b211a9747c5fb807a3f2767fa22 (patch)
tree572bc13c87a726cbc7132043cc1d10af795f442b /src/main/java/io/trygvis/esper/testing/ResourceManager.java
parentff34cdc13bc8ba0943cded8009b9869a455894f6 (diff)
downloadesper-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.java31
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;
+ }
+ }
+}