summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorGravatar Matthias Jaros <jarlucmat@mailbox.org>2026-08-01 21:57:30 +0200
committerGravatar Matthias Jaros <jarlucmat@mailbox.org>2026-08-01 21:57:30 +0200
commit261839fb33c937633ba39c47611cfa11a41f0c7b (patch)
treece91140dbd35f2de1a60cd794b314f286a00953c /src
parent2f988ae62cfb12f6ffecb1ba72fdabec3b1c0771 (diff)
Make method better readable
Diffstat (limited to 'src')
-rw-r--r--src/main/java/com/it_jaros/jscanner/Scanner.java7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/main/java/com/it_jaros/jscanner/Scanner.java b/src/main/java/com/it_jaros/jscanner/Scanner.java
index 6d3fd96..337f5ed 100644
--- a/src/main/java/com/it_jaros/jscanner/Scanner.java
+++ b/src/main/java/com/it_jaros/jscanner/Scanner.java
@@ -123,7 +123,12 @@ public class Scanner implements AutoCloseable {
* @param <OUTPUT>
* @return
*/
- private <INPUT, OUTPUT> ProducerState<OUTPUT> startProducer(Iterator<INPUT> queue, int maxWorkers, Function<INPUT, Callable<OUTPUT>> taskFactory, Counter threadCounter) {
+ private <INPUT, OUTPUT> ProducerState<OUTPUT> startProducer(
+ Iterator<INPUT> queue,
+ int maxWorkers,
+ Function<INPUT, Callable<OUTPUT>> taskFactory,
+ Counter threadCounter
+ ) {
final AtomicInteger inPipeline = new AtomicInteger(0);
final AtomicBoolean running = new AtomicBoolean(true);
final Semaphore activeWorkers = new Semaphore(maxWorkers);