Skip to content

Commit 84782d0

Browse files
abialasmaibin
authored andcommitted
BAEL-21 (eugenp#3587)
* BAEL-1412 add java 8 spring data features * BAEL-21 new HTTP API overview * BAEL-21 fix executor
1 parent 8ada19d commit 84782d0

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

core-java-9/src/test/java/com/baeldung/java9/httpclient/HttpClientTest.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import java.util.List;
1212
import java.util.concurrent.CompletableFuture;
1313
import java.util.concurrent.ExecutionException;
14+
import java.util.concurrent.ExecutorService;
1415
import java.util.concurrent.Executors;
1516
import 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

0 commit comments

Comments
 (0)