geforkt von Mirrors/Velocity
Optimize DNS resolution logic for AsyncHttpClient
Dieser Commit ist enthalten in:
Ursprung
75359256b3
Commit
8c3f7e2ecc
@ -7,6 +7,7 @@ import io.netty.util.concurrent.EventExecutor;
|
|||||||
import io.netty.util.concurrent.FutureListener;
|
import io.netty.util.concurrent.FutureListener;
|
||||||
import io.netty.util.concurrent.ImmediateEventExecutor;
|
import io.netty.util.concurrent.ImmediateEventExecutor;
|
||||||
import io.netty.util.concurrent.Promise;
|
import io.netty.util.concurrent.Promise;
|
||||||
|
import io.netty.util.internal.ThreadExecutorMap;
|
||||||
import java.net.InetAddress;
|
import java.net.InetAddress;
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
@ -61,13 +62,7 @@ public class DnsAddressResolverGroupNameResolverAdapter extends InetNameResolver
|
|||||||
}
|
}
|
||||||
|
|
||||||
private EventExecutor findExecutor() {
|
private EventExecutor findExecutor() {
|
||||||
for (EventExecutor executor : group) {
|
EventExecutor current = ThreadExecutorMap.currentExecutor();
|
||||||
if (executor.inEventLoop()) {
|
return current == null ? group.next() : current;
|
||||||
return executor;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// otherwise, pick one
|
|
||||||
return group.next();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Laden…
In neuem Issue referenzieren
Einen Benutzer sperren