Working version with semaphore counter and rate limiter

1 files changed, 25 insertions, 0 deletions

diff --git a/src/main/java/com/it_jaros/networkScanner/Counter.java b/src/main/java/com/it_jaros/networkScanner/Counter.java
new file mode 100644
index 0000000..a4baec0
--- /dev/null
+++ b/src/main/java/com/it_jaros/networkScanner/Counter.java
@@ -0,0 +1,25 @@
+package com.it_jaros.networkScanner;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+public final class Counter {
+    private final AtomicInteger current = new AtomicInteger(0);
+    private final AtomicInteger max = new AtomicInteger(0);
+
+    public void inc() {
+        int now = current.incrementAndGet();
+        max.accumulateAndGet(now, Math::max);
+    }
+
+    public void dec() {
+        current.decrementAndGet();
+    }
+
+    public int current() {
+        return current.get();
+    }
+
+    public int max() {
+        return max.get();
+    }
+}