diff options
| -rw-r--r-- | src/main/java/com/it_jaros/jscanner/Scanner.java | 4 |
1 files changed, 2 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 df6b30d..659b62b 100644 --- a/src/main/java/com/it_jaros/jscanner/Scanner.java +++ b/src/main/java/com/it_jaros/jscanner/Scanner.java @@ -95,7 +95,7 @@ public class Scanner implements AutoCloseable { } private PollState<ScanResult> getHostResult(ProducerState<ScanResult> state) throws InterruptedException { - Future<ScanResult> finishedHost = state.completionService().poll(10, TimeUnit.MILLISECONDS); + Future<ScanResult> finishedHost = state.completionService().poll(500, TimeUnit.MILLISECONDS); if (finishedHost == null) { return new PollState.Unavailable<>(); } @@ -274,7 +274,7 @@ public class Scanner implements AutoCloseable { } private PollState<PortResult> getPortResult(ProducerState<PortResult> state) throws InterruptedException { - Future<PortResult> portResultFuture = state.completionService().poll(10, TimeUnit.MILLISECONDS); + Future<PortResult> portResultFuture = state.completionService().poll(500, TimeUnit.MILLISECONDS); if (portResultFuture == null) { return new PollState.Unavailable<>(); } |