返回连续运行的子进程的承诺

Question

我正在尝试产生子进程，并在Promise中产生结果。 子进程不能同时运行多次。

我在承诺中包装node.js的child_process.spawn()。 承诺在成功退出成功时履行，否则拒绝。 请求在不同时间com有时一个有时多个。我需要为每个请求执行相同的命令，甚至可以多次（使用不同或可能相同的选项）来完成请求。但是，如果并行运行，该命令将被锁定。所以如果不确定事先没有退出就不能运行。

也许我需要他们排队？

我无法把我的头围绕如何在JavaScript/Typescript中做到这一点。忙碌的等待显然不是上帝的主意，但我希望它能解释我想在这里做什么。

export class RunThingy{ 

private busy: boolean; 

constructor() { 
    this.busy = false; 
} 

private run(options: string[]): Promise<string> { 
    return new Promise((resolve, reject) => { 
    let stdout: string = ''; 
    let stderr: string = ''; 
    while (!this.busy) {    //Problem 
     this.busy = true; 
     let process: ChildProcess = spawn('processName', options); 
     process.stdout.on('data', (contents) => { stdout += contents; }); 
     process.stderr.on('data', (contents) => { stderr += contents; }); 
     process 
     .on('error', reject) 
     .on('close', function (code) { 
      if (code === 0) { 
      resolve(stdout); 
      } else { 
      reject(stderr); 
      } 
      this.buisy = false;  //Problem 
     }); 
    } 
    }); 
} 

编辑：更名为command[]到options[]

Answer 1

允诺可以拒绝或下不为例。每个流程都必须包含在承诺中。这是一个命题：

export class RunThingy { 
    private curCommand: Promise<string> | null 

    private run(options: string[]): Promise<string> { 
     let next: Promise<string> 
     if (this.curCommand) { 
      next = this.curCommand.then(
       () => runCommand(options), // the next command will be started after 
       () => runCommand(options) // the current will be resolved or rejected 
      ) 
     } else 
      next = runCommand(options) 
     next = next.then(stdout => { 
      if (next === this.curCommand) // if this is the last command 
       this.curCommand = null // then forget the current command 
      return stdout     // return the command value 
     }, err => { 
      if (next === this.curCommand) // if this is the last command 
       this.curCommand = null // then forget the current command 
      throw err      // throw again the error 
     }) 
     this.curCommand = next 
     return this.curCommand 
    } 
} 

function runCommand(options: string[]): Promise<string> { 
    return new Promise((resolve, reject) => { 
     let stdout = ''; 
     let stderr = ''; 
     let process: ChildProcess = spawn('processName', options); 
     process.stdout.on('data', (contents) => { stdout += contents; }); 
     process.stderr.on('data', (contents) => { stderr += contents; }); 
     process 
      .on('error', reject) 
      .on('close', function (code) { 
       if (code === 0) { 
        resolve(stdout); 
       } else { 
        reject(new Error(stderr)); 
       } 
      }); 
    }); 
} 

在该方法中run，我们检查是否有电流命令。新命令将在当前命令解决或拒绝后启动。