From 3ec14e0071dae2233b278b6c5b3235e1926f7047 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Simon=20K=C3=B6nnecke?= <simonkoennecke@gmail.com> Date: Fri, 8 Jul 2016 00:16:20 +0200 Subject: [PATCH] add q-digest data structure --- pom.xml | 6 +++++- src/main/java/fucoin/wallet/WalletImpl.java | 4 ++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index a9f4391..f81f424 100644 --- a/pom.xml +++ b/pom.xml @@ -62,6 +62,10 @@ <artifactId>jgraphx</artifactId> <version>1.10.1.3</version> </dependency> - + <dependency> + <groupId>it.unimi.dsi</groupId> + <artifactId>fastutil</artifactId> + <version>7.0.12</version> + </dependency> </dependencies> </project> \ No newline at end of file diff --git a/src/main/java/fucoin/wallet/WalletImpl.java b/src/main/java/fucoin/wallet/WalletImpl.java index 6f668e5..88e64c9 100644 --- a/src/main/java/fucoin/wallet/WalletImpl.java +++ b/src/main/java/fucoin/wallet/WalletImpl.java @@ -21,6 +21,9 @@ import java.util.concurrent.ConcurrentLinkedQueue; public class WalletImpl extends AbstractWallet { + private static final double sCompression = 0.7; + private QDigest qDigest = new QDigest(sCompression); + private ActorRef preKnownNeighbour; private ActorRef remoteSuperVisorActor; private transient WalletGuiControl gui; @@ -51,6 +54,7 @@ public class WalletImpl extends AbstractWallet { */ public void addAmount(int amount) { setAmount(this.getAmount() + amount); + qDigest.offer(amount); addLogMsg(" My amount is now " + this.getAmount()); } -- GitLab