configurable queue

run.ts

@@ -28,6 +28,7 @@ interface Config {
   timeout: number;
   retryCount: number;
   interval: number;
+  cocurrent: number;
 }
 
 interface DomainRecordObject {
@@ -203,7 +204,7 @@ class Checker {
     }
   }
 
-  private queue = new PQueue({ concurrency: 100 });
+  private queue: PQueue;
 
   private async tryConnectHttp(
     protocol: string,
@@ -344,6 +345,7 @@ class Checker {
     }
   }
   constructor(private config: Config) {
+    this.queue = new PQueue({ concurrency: this.config.cocurrent || 10 });
     this.client = new Aliyun(config.aliyun);
     this.cdnRecordsRegex = config.cdnRecords.map((m) => new RegExp(m.match));
     this.id = ++Checker.order;