handle dns thread pool

Author: yangsen

library/src/main/java/com/qiniu/android/http/dns/HttpDns.java

@@ -10,21 +10,28 @@
 import java.net.UnknownHostException;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
 
 public class HttpDns implements Dns {
 
     private IResolver httpIpv4Resolver;
     private IResolver httpIpv6Resolver;
 
+    private static final ExecutorService executor = new ThreadPoolExecutor(0, 4,
+            60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
+
     public HttpDns(int timeout) {
         String[] dohIpv4Servers = GlobalConfiguration.getInstance().getDohIpv4Servers();
         if (dohIpv4Servers != null && dohIpv4Servers.length > 0) {
-            httpIpv4Resolver = new DohResolver(dohIpv4Servers, Record.TYPE_A, timeout);
+            httpIpv4Resolver = new DohResolver(dohIpv4Servers, Record.TYPE_A, timeout, executor);
         }
 
         String[] dohIpv6Servers = GlobalConfiguration.getInstance().getDohIpv6Servers();
         if (dohIpv6Servers != null && dohIpv6Servers.length > 0) {
-            httpIpv6Resolver = new DohResolver(dohIpv6Servers, Record.TYPE_A, timeout);
+            httpIpv6Resolver = new DohResolver(dohIpv6Servers, Record.TYPE_A, timeout, executor);
         }
     }
 

library/src/main/java/com/qiniu/android/http/dns/SystemDns.java

@@ -22,7 +22,7 @@
 public class SystemDns implements Dns {
 
     private int timeout = 10;
-    private static final ExecutorService executor = new ThreadPoolExecutor(1, 3,
+    private static final ExecutorService executor = new ThreadPoolExecutor(0, 4,
             60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
 
     public SystemDns() {

library/src/main/java/com/qiniu/android/http/dns/UdpDns.java

@@ -10,20 +10,27 @@
 import java.net.UnknownHostException;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
 
 public class UdpDns implements Dns {
     private IResolver udpIpv4Resolver;
     private IResolver udpIpv6Resolver;
 
+    private static final ExecutorService executor = new ThreadPoolExecutor(0, 4,
+            60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
+
     public UdpDns(int timeout) {
         String[] udpIpv4Servers = GlobalConfiguration.getInstance().getUdpDnsIpv4Servers();
         if (udpIpv4Servers != null && udpIpv4Servers.length > 0) {
-            udpIpv4Resolver = new DnsUdpResolver(udpIpv4Servers, Record.TYPE_A, timeout);
+            udpIpv4Resolver = new DnsUdpResolver(udpIpv4Servers, Record.TYPE_A, timeout, executor);
         }
 
         String[] udpIpv6Servers = GlobalConfiguration.getInstance().getUdpDnsIpv6Servers();
         if (udpIpv6Servers != null && udpIpv6Servers.length > 0) {
-            udpIpv6Resolver = new DnsUdpResolver(udpIpv6Servers, Record.TYPE_A, timeout);
+            udpIpv6Resolver = new DnsUdpResolver(udpIpv6Servers, Record.TYPE_A, timeout, executor);
         }
     }