summaryrefslogtreecommitdiff
path: root/src/main/java/com/it_jaros/jscanner/scan/engine/ProducerState.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/it_jaros/jscanner/scan/engine/ProducerState.java')
-rw-r--r--src/main/java/com/it_jaros/jscanner/scan/engine/ProducerState.java13
1 files changed, 13 insertions, 0 deletions
diff --git a/src/main/java/com/it_jaros/jscanner/scan/engine/ProducerState.java b/src/main/java/com/it_jaros/jscanner/scan/engine/ProducerState.java
new file mode 100644
index 0000000..c49ea3e
--- /dev/null
+++ b/src/main/java/com/it_jaros/jscanner/scan/engine/ProducerState.java
@@ -0,0 +1,13 @@
+package com.it_jaros.jscanner.scan.engine;
+
+import java.util.concurrent.CompletionService;
+import java.util.concurrent.Semaphore;
+import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicInteger;
+
+public record ProducerState<OUTPUT>(
+ AtomicBoolean running,
+ AtomicInteger inPipeline,
+ Semaphore activeWorkers,
+ CompletionService<OUTPUT> completionService
+) {}