no message

README.md

@@ -51,4 +51,34 @@ jobExecutor.register("demoJobHandler", async (args) => {
     }
     }
 
 
     return { result: 'return value' };
     return { result: 'return value' };
-})
\ No newline at end of file
+})
+
+//批量任务注册
+const batchJob = [
+    [
+        "demoJobHandler1",
+        async (args) => {
+            for (let i = 1; i < 10; i++) {
+                await new Promise((resolve, reject) => {
+                    setTimeout(resolve, 888);
+                })
+            }
+
+            return { result: 'return value' };
+        }
+    ],
+       [
+        "demoJobHandler2",
+        async (args) => {
+            for (let i = 1; i < 10; i++) {
+                await new Promise((resolve, reject) => {
+                    setTimeout(resolve, 888);
+                })
+            }
+
+            return { result: 'return value' };
+        }
+    ]
+]
+
+jobExecutor.registerBatch(batchJob);
\ No newline at end of file

build/index.js

@@ -36,7 +36,7 @@ class JobExecutor {
         });
         });
     }
     }
     registerBatch(handlers) {
     registerBatch(handlers) {
-        handlers.forEach((handler, jobName) => this.register(jobName, handler));
+        handlers.forEach((handler) => this.register(handler[0], handler[1]));
     }
     }
     getJobHandler(jobName) {
     getJobHandler(jobName) {
         return this.jobHandlers.get(jobName);
         return this.jobHandlers.get(jobName);

build/test.js

@@ -25,4 +25,29 @@ jobExecutor.register("demoJobHandler", async (args) => {
     }
     }
     return { result: 'return value' };
     return { result: 'return value' };
 });
 });
+const batchJob = [
+    [
+        "demoJobHandler1",
+        async (args) => {
+            for (let i = 1; i < 10; i++) {
+                await new Promise((resolve, reject) => {
+                    setTimeout(resolve, 888);
+                });
+            }
+            return { result: 'return value' };
+        }
+    ],
+    [
+        "demoJobHandler2",
+        async (args) => {
+            for (let i = 1; i < 10; i++) {
+                await new Promise((resolve, reject) => {
+                    setTimeout(resolve, 888);
+                });
+            }
+            return { result: 'return value' };
+        }
+    ]
+];
+jobExecutor.registerBatch(batchJob);
 //# sourceMappingURL=test.js.map
 //# sourceMappingURL=test.js.map
\ No newline at end of file

src/index.ts

@@ -92,10 +92,11 @@ export class JobExecutor {
 
 
     /** 
     /** 
      * 批量注册任务
      * 批量注册任务
-     * @param handlers 任务处理函数，需返回 Promise
+     * @param handlers Array<[string, Function]> 任务处理函数，需返回 Promise
+     * 
      */
      */
-    public registerBatch(handlers: Map<string, Function>) {
-        handlers.forEach((handler, jobName) => this.register(jobName, handler));
+    public registerBatch(handlers: any[]) {
+        handlers.forEach((handler) => this.register(handler[0], handler[1]));
     }
     }
 
 
     /**
     /**

src/test.ts

@@ -27,4 +27,34 @@ jobExecutor.register("demoJobHandler", async (args) => {
     }
     }
 
 
     return { result: 'return value' };
     return { result: 'return value' };
-})
\ No newline at end of file
+})
+
+//批量任务注册
+const batchJob = [
+    [
+        "demoJobHandler1",
+        async (args) => {
+            for (let i = 1; i < 10; i++) {
+                await new Promise((resolve, reject) => {
+                    setTimeout(resolve, 888);
+                })
+            }
+
+            return { result: 'return value' };
+        }
+    ],
+       [
+        "demoJobHandler2",
+        async (args) => {
+            for (let i = 1; i < 10; i++) {
+                await new Promise((resolve, reject) => {
+                    setTimeout(resolve, 888);
+                })
+            }
+
+            return { result: 'return value' };
+        }
+    ]
+]
+
+jobExecutor.registerBatch(batchJob);
\ No newline at end of file