File tree Expand file tree Collapse file tree
core-java-9/src/test/java/com/baeldung/java9/httpclient Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1111import java .util .List ;
1212import java .util .concurrent .CompletableFuture ;
1313import java .util .concurrent .ExecutionException ;
14+ import java .util .concurrent .ExecutorService ;
1415import java .util .concurrent .Executors ;
1516import java .util .stream .Collectors ;
1617
@@ -116,18 +117,20 @@ public void shouldUseJustTwoThreadWhenProcessingSendAsyncRequest() throws URISyn
116117 .GET ()
117118 .build ();
118119
120+ ExecutorService executorService = Executors .newFixedThreadPool (2 );
121+
119122 CompletableFuture <HttpResponse <String >> response1 = HttpClient .newBuilder ()
120- .executor (Executors . newFixedThreadPool ( 2 ) )
123+ .executor (executorService )
121124 .build ()
122125 .sendAsync (request , HttpResponse .BodyHandler .asString ());
123126
124127 CompletableFuture <HttpResponse <String >> response2 = HttpClient .newBuilder ()
125- .executor (Executors . newFixedThreadPool ( 2 ) )
128+ .executor (executorService )
126129 .build ()
127130 .sendAsync (request , HttpResponse .BodyHandler .asString ());
128131
129132 CompletableFuture <HttpResponse <String >> response3 = HttpClient .newBuilder ()
130- .executor (Executors . newFixedThreadPool ( 2 ) )
133+ .executor (executorService )
131134 .build ()
132135 .sendAsync (request , HttpResponse .BodyHandler .asString ());
133136
You can’t perform that action at this time.
0 commit comments