feat: add configurable polling interval for CloudflareSolver

- Introduced a new pollingInterval parameter to allow customization of the polling delay in CloudflareSolver.
- Updated LinkSocksManager and MaskTunnelManager to use a configurable startup wait time.

Author: zetxtech

src/main/java/site/zetx/cloudflyer/CloudflareSolver.java

@@ -40,6 +40,7 @@ public class CloudflareSolver implements AutoCloseable {
     private final boolean solve;
     private final boolean onChallenge;
     private final boolean usePolling;
+    private final int pollingInterval;
     private final int timeout;
     private final String proxy;
     private final boolean useLinkSocks;
@@ -71,6 +72,7 @@ private CloudflareSolver(Builder builder) {
         this.solve = builder.solve;
         this.onChallenge = builder.onChallenge;
         this.usePolling = builder.usePolling;
+        this.pollingInterval = builder.pollingInterval;
         this.timeout = builder.timeout;
         this.proxy = builder.proxy;
         this.useLinkSocks = builder.useLinkSocks;
@@ -520,7 +522,7 @@ private JsonObject waitForResult(String taskId, int timeout) throws CFSolverExce
             try (okhttp3.Response response = pollClient.newCall(request).execute()) {
                 if (response.code() != 200) {
                     if (usePolling) {
-                        Thread.sleep(2000);
+                        Thread.sleep(pollingInterval);
                     }
                     continue;
                 }
@@ -531,7 +533,7 @@ private JsonObject waitForResult(String taskId, int timeout) throws CFSolverExce
 
                 if ("processing".equals(status)) {
                     if (usePolling) {
-                        Thread.sleep(2000);
+                        Thread.sleep(pollingInterval);
                     }
                     continue;
                 }
@@ -567,7 +569,7 @@ private JsonObject waitForResult(String taskId, int timeout) throws CFSolverExce
             } catch (IOException e) {
                 if (usePolling) {
                     try {
-                        Thread.sleep(2000);
+                        Thread.sleep(pollingInterval);
                     } catch (InterruptedException ie) {
                         Thread.currentThread().interrupt();
                     }
@@ -930,6 +932,7 @@ public static class Builder {
         private boolean solve = true;
         private boolean onChallenge = true;
         private boolean usePolling = false;
+        private int pollingInterval = 2000;
         private int timeout = 30000;
         private String proxy;
         private okhttp3.Authenticator proxyAuth;
@@ -986,6 +989,17 @@ public Builder usePolling(boolean usePolling) {
             return this;
         }
 
+        /**
+         * Set the interval between polling attempts when usePolling is true.
+         * 
+         * @param pollingInterval interval in milliseconds (default: 2000)
+         * @return this builder
+         */
+        public Builder pollingInterval(int pollingInterval) {
+            this.pollingInterval = pollingInterval;
+            return this;
+        }
+        
         /**
          * Set the request timeout in milliseconds.
          * 

src/main/java/site/zetx/cloudflyer/LinkSocksManager.java

@@ -25,6 +25,7 @@ class LinkSocksManager {
     private final OkHttpClient httpClient;
     private final String upstreamProxy;
     private final ToolDownloader toolDownloader;
+    private final int startupWaitMs;
 
     private Process linksocksProcess;
     private LinkSocksConfig config;
@@ -52,10 +53,15 @@ String getWsUrl() {
     }
 
     LinkSocksManager(String apiBase, String apiKey, OkHttpClient httpClient, String upstreamProxy) {
+        this(apiBase, apiKey, httpClient, upstreamProxy, 2000);
+    }
+    
+    LinkSocksManager(String apiBase, String apiKey, OkHttpClient httpClient, String upstreamProxy, int startupWaitMs) {
         this.apiBase = apiBase;
         this.apiKey = apiKey;
         this.httpClient = httpClient;
         this.upstreamProxy = upstreamProxy;
+        this.startupWaitMs = startupWaitMs;
         this.toolDownloader = new ToolDownloader(httpClient);
     }
 
@@ -120,7 +126,7 @@ synchronized void connect() throws IOException {
 
         // Wait for connection
         try {
-            Thread.sleep(2000);
+            Thread.sleep(startupWaitMs);
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
         }

src/main/java/site/zetx/cloudflyer/MaskTunnelManager.java

@@ -24,19 +24,25 @@ public class MaskTunnelManager implements Closeable {
     private final int port;
     private final String upstreamProxy;
     private final ToolDownloader toolDownloader;
+    private final int startupWaitMs;
     private Process process;
     private Thread outputThread;
     private Thread errorThread;
 
     public MaskTunnelManager(String addr, int port, String upstreamProxy, OkHttpClient httpClient) {
+        this(addr, port, upstreamProxy, httpClient, 2000);
+    }
+    
+    public MaskTunnelManager(String addr, int port, String upstreamProxy, OkHttpClient httpClient, int startupWaitMs) {
         this.addr = addr;
         this.port = port;
         this.upstreamProxy = upstreamProxy;
         this.toolDownloader = new ToolDownloader(httpClient);
+        this.startupWaitMs = startupWaitMs;
     }
 
     public MaskTunnelManager(int port, String upstreamProxy, OkHttpClient httpClient) {
-        this("127.0.0.1", port, upstreamProxy, httpClient);
+        this("127.0.0.1", port, upstreamProxy, httpClient, 2000);
     }
 
     /**
@@ -70,7 +76,7 @@ public void start() throws IOException {
 
         // Wait for startup
         try {
-            Thread.sleep(2000);
+            Thread.sleep(startupWaitMs);
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
         }