File tree 1 file changed +4
-1
lines changed
client/src/main/java/org/asynchttpclient 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change 30
30
import java .util .Map ;
31
31
import java .util .Properties ;
32
32
import java .util .concurrent .ThreadFactory ;
33
+ import java .util .concurrent .atomic .AtomicInteger ;
33
34
34
35
import org .asynchttpclient .channel .pool .KeepAliveStrategy ;
35
36
import org .asynchttpclient .filter .IOExceptionFilter ;
@@ -515,6 +516,8 @@ public ResponseBodyPartFactory getResponseBodyPartFactory() {
515
516
* Builder for an {@link AsyncHttpClient}
516
517
*/
517
518
public static class Builder {
519
+
520
+ private static final AtomicInteger COUNTER = new AtomicInteger ();
518
521
519
522
// http
520
523
private boolean followRedirect = defaultFollowRedirect ();
@@ -564,7 +567,7 @@ public static class Builder {
564
567
private final List <IOExceptionFilter > ioExceptionFilters = new LinkedList <>();
565
568
566
569
// internals
567
- private String threadPoolName = defaultThreadPoolName ();
570
+ private String threadPoolName = defaultThreadPoolName () + COUNTER . getAndIncrement () ;
568
571
private int httpClientCodecMaxInitialLineLength = defaultHttpClientCodecMaxInitialLineLength ();
569
572
private int httpClientCodecMaxHeaderSize = defaultHttpClientCodecMaxHeaderSize ();
570
573
private int httpClientCodecMaxChunkSize = defaultHttpClientCodecMaxChunkSize ();
You can’t perform that action at this time.
0 commit comments