diff options
| -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); |