diff options
| author | 2026-08-01 21:57:30 +0200 | |
|---|---|---|
| committer | 2026-08-01 21:57:30 +0200 | |
| commit | 261839fb33c937633ba39c47611cfa11a41f0c7b (patch) | |
| tree | ce91140dbd35f2de1a60cd794b314f286a00953c /src/main/java/com | |
| parent | 2f988ae62cfb12f6ffecb1ba72fdabec3b1c0771 (diff) | |
Make method better readable
Diffstat (limited to 'src/main/java/com')
| -rw-r--r-- | src/main/java/com/it_jaros/jscanner/Scanner.java | 7 |
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); |
