diff options
| -rw-r--r-- | src/main/java/com/it_jaros/jscanner/Scanner.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/java/com/it_jaros/jscanner/Scanner.java b/src/main/java/com/it_jaros/jscanner/Scanner.java index beeb62e..71933a9 100644 --- a/src/main/java/com/it_jaros/jscanner/Scanner.java +++ b/src/main/java/com/it_jaros/jscanner/Scanner.java @@ -17,6 +17,7 @@ import java.util.function.Function; public class Scanner implements AutoCloseable { + private static final Duration pollInterval = Duration.ofSeconds(1); private static final int READ_BUFFER_SIZE = 1024; private volatile boolean cancelled = false; @@ -96,7 +97,7 @@ public class Scanner implements AutoCloseable { } private PollState<ScanResult> getHostResult(ProducerState<ScanResult> state) throws InterruptedException { - Future<ScanResult> finishedHost = state.completionService().poll(500, TimeUnit.MILLISECONDS); + Future<ScanResult> finishedHost = state.completionService().poll(pollInterval.toMillis(), TimeUnit.MILLISECONDS); if (finishedHost == null) { return new PollState.Unavailable<>(); } @@ -277,7 +278,7 @@ public class Scanner implements AutoCloseable { } private PollState<PortResult> getPortResult(ProducerState<PortResult> state) throws InterruptedException { - Future<PortResult> portResultFuture = state.completionService().poll(500, TimeUnit.MILLISECONDS); + Future<PortResult> portResultFuture = state.completionService().poll(pollInterval.toMillis(), TimeUnit.MILLISECONDS); if (portResultFuture == null) { return new PollState.Unavailable<>(); } |