diff options
| author | Jon Bratseth <bratseth@oath.com> | 2021-04-21 20:47:51 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-04-21 20:47:51 +0200 |
| commit | daa7010d1d953e7c18f74e9e46755d9a250a353a (patch) | |
| tree | 263f79baf896a617f320409c6dc8bacb0a71c967 /container-search | |
| parent | bc3caa587f166d02e90b8bb81a1656a6cdd32715 (diff) | |
| parent | f85a43cfbffd05096eb968a37ef480780be49512 (diff) | |
Merge pull request #17514 from vespa-engine/bratseth/redundancy
Bratseth/redundancy
Diffstat (limited to 'container-search')
| -rw-r--r-- | container-search/src/test/java/com/yahoo/search/searchchain/test/AsyncExecutionOfOneChainTestCase.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/container-search/src/test/java/com/yahoo/search/searchchain/test/AsyncExecutionOfOneChainTestCase.java b/container-search/src/test/java/com/yahoo/search/searchchain/test/AsyncExecutionOfOneChainTestCase.java index 182ec7568f3..28ad202c4f5 100644 --- a/container-search/src/test/java/com/yahoo/search/searchchain/test/AsyncExecutionOfOneChainTestCase.java +++ b/container-search/src/test/java/com/yahoo/search/searchchain/test/AsyncExecutionOfOneChainTestCase.java @@ -48,20 +48,20 @@ public class AsyncExecutionOfOneChainTestCase { private class ParallelExecutor extends Searcher { /** The number of parallel executions */ - private static final int parallelism=2; + private static final int parallelism = 2; @Override public Result search(Query query, Execution execution) { - List<FutureResult> futureResults=new ArrayList<>(parallelism); - for (int i=0; i<parallelism; i++) + List<FutureResult> futureResults = new ArrayList<>(parallelism); + for (int i = 0; i < parallelism; i++) futureResults.add(new AsyncExecution(execution).search(query.clone())); - Result mainResult=execution.search(query); + Result mainResult = execution.search(query); // Add hits from other threads AsyncExecution.waitForAll(futureResults,query.getTimeLeft()); for (FutureResult futureResult : futureResults) { - Result result=futureResult.get(); + Result result = futureResult.get(); mainResult.mergeWith(result); mainResult.hits().addAll(result.hits().asList()); } @@ -72,7 +72,7 @@ public class AsyncExecutionOfOneChainTestCase { private static class RegularProvider extends Searcher { - private AtomicInteger counter=new AtomicInteger(); + private final AtomicInteger counter = new AtomicInteger(); @Override public Result search(Query query,Execution execution) { |