feat: 命令行添加参数-c, --concurrency，用于设置并发数量，默认为5个

axetroy · Dec 3, 2017 · 292d0f2 · 292d0f2
1 parent 431ac9c
commit 292d0f2
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/app/app.js b/app/app.js
@@ -196,7 +196,7 @@ class App extends EventEmitter {
             this.emit(EVENT_ON_ERROR, err);
           }
         },
-        { concurrency: 5 }
+        { concurrency: this.options.concurrency }
       );
     } catch (err) {
       this.emit(EVENT_ON_ERROR, err);

diff --git a/bin/boomer b/bin/boomer
@@ -13,11 +13,13 @@ program
   .option('-f, --forever', '永久运行，默认只运行一次', program.BOOLEAN, false)
   .option('--dev', '以开发者模式运行，则显示浏览器运行过程', program.BOOLEAN, false)
   .option('--launch <provider>', '如果是开发模式，则指定站点名称<provider>', program.STRING, '')
+  .option('-c, --concurrency <number>', '设置并发数量', program.INT, 5)
   .action((argv, opts) => {
     const app = boomer(argv.phone || process.env.PHONE || '13800000000', {
       once: !opts.forever,
       isProduction: !opts.dev,
-      launchProvider: opts.launch
+      launchProvider: opts.launch,
+      concurrency: opts.concurrency
     });
 
     app

diff --git a/index.js b/index.js
@@ -28,7 +28,8 @@ const defaultOptions = {
   },
   password: 'abc123abc123',
   phone: '13000000000', // do not set default phone number
-  once: isProduction === false
+  once: isProduction === false,
+  concurrency: 5
 };
 
 module.exports = function(phoneNumber, options) {