20

我的具体问题是我需要执行（可能）大量的 Javascript 函数来准备批处理文件之类的东西（每个函数调用都会将一些信息添加到同一个批处理文件中），然后在所有这些调用完成后，执行发送批处理文件的最终函数（例如，将其作为 HTML 响应发送）。我正在为此寻找通用的 Javascript 编程模式。

概括问题：给定 Javascript 函数 funcA()、funcB() 和 funcC()，我想找出排序执行的最佳方法，以便 funcC 仅在 funcA 和 funcB 执行后执行。我知道我可以使用这样的嵌套回调函数：

funcA = function() {
    //Does funcA stuff
    funcB();
}
funcB = function() {
    //Does funcB stuff
    funcC();
}

funcA();

我什至可以通过传入回调参数使这个模式更通用一些，但是，这个解决方案变得非常冗长。

我也熟悉 Javascript 函数链接，其中的解决方案可能如下所示：

myObj = {}
myObj.answer = ""
myObj.funcA = function() {
    //Do some work on this.answer
    return this;
}
myObj.funcB = function() {
    //Do some more work on this.answer
    return this;
}
myObj.funcC = function() {
    //Use the value of this.answer now that funcA and funcB have made their modifications
    return this;
}
myObj.funcA().funcB().funcC();

虽然这个解决方案对我来说似乎更简洁一些，但随着您向计算中添加更多步骤，函数执行链会变得越来越长。

对于我的具体问题，funcA、funcB 等的执行顺序并不重要。因此，在我上面的解决方案中，我在技术上做的工作比需要的要多，因为我将所有功能都按顺序排列。对我来说重要的是 funcC （一些用于发送结果或触发请求的函数）仅在 funcA 和 funcB 完成执行后才被调用。理想情况下，funcC 可以以某种方式侦听所有要完成的中间函数调用，然后执行？我希望学习一个通用的 Javascript 模式来解决这样的问题。

谢谢你的帮助。

另一个想法：也许将共享对象传递给 funcA 和 funcB 并在它们完成执行时标记共享对象，如 sharedThing.funcA = "complete" 或 sharedThing.funcB = "complete" 然后以某种方式？当共享对象达到所有字段都标记为完成的状态时，执行 funcC。我不确定你如何让 funcC 等待这个。

编辑：我应该注意我正在使用服务器端 Javascript（Node.js），我想学习一种模式来解决它，只需使用普通的旧 Javascript（不使用 jQuery 或其他库）。当然，这个问题足够普遍，以至于有一个干净的纯 JavaScript 解决方案？

4

7 回答 7

9

如果你想保持简单，你可以使用基于计数器的回调系统。这是一个允许when(A, B).then(C)语法的系统草案。（when/then实际上只是糖，但整个系统也可以说是。）

var when = function() {
  var args = arguments;  // the functions to execute first
  return {
    then: function(done) {
      var counter = 0;
      for(var i = 0; i < args.length; i++) {
        // call each function with a function to call on done
        args[i](function() {
          counter++;
          if(counter === args.length) {  // all functions have notified they're done
            done();
          }
        });
      }
    }
  };
};

用法：

when(
  function(done) {
    // do things
    done();
  },
  function(done) {
    // do things
    setTimeout(done, 1000);
  },
  ...
).then(function() {
  // all are done
});
于 2012-06-30T22:20:14.253 回答
3

如果您不使用任何异步函数并且您的脚本没有破坏执行顺序，那么最简单的解决方案是，如 Pointy 和其他人所述：

funcA(); 
funcB();
funcC();

但是，由于您使用的是 node.js，我相信您将使用异步函数并希望funcC在异步 IO 请求完成后执行，因此您必须使用某种计数机制，例如：

var call_after_completion = function(callback){
    this._callback = callback;
    this._args = [].slice.call(arguments,1);
    this._queue = {};
    this._count = 0;
    this._run = false;
}

call_after_completion.prototype.add_condition = function(str){
    if(this._queue[str] !== undefined)
        throw new TypeError("Identifier '"+str+"' used twice");
    else if(typeof str !== "String" && str.toString === undefined)
        throw new TypeError("Identifier has to be a string or needs a toString method");

    this._queue[str] = 1;
    this._count++;
    return str;
}

call_after_completion.prototype.remove_condition = function(str){
    if(this._queue[str] === undefined){
        console.log("Removal of condition '"+str+"' has no effect");
        return;
    }
    else if(typeof str !== "String" && str.toString === undefined)
        throw new TypeError("Identifier has to be a string or needs a toString method");

    delete this._queue[str];

    if(--this._count === 0 && this._run === false){
        this._run = true;
        this._callback.apply(null,this._args);
    }
}

您可以通过忽略标识符str并仅增加/减少来简化此对象this._count，但是此系统可能对调试有用。

为了使用call_after_completion，您只需使用new call_after_completion所需的函数func作为参数和add_conditions 创建一个。func只有在所有条件都被删除后才会被调用。

例子：

var foo = function(){console.log("foo");}
var bar = new call_after_completion(foo);
var i;

bar.add_condition("foo:3-Second-Timer");
bar.add_condition("foo:additional function");
bar.add_condition("foo:for-loop-finished");

function additional_stuff(cond){
    console.log("additional things");
    cond.remove_condition("foo:additional function");
}

for(i = 0; i < 1000; ++i){

}
console.log("for loop finished");
bar.remove_condition("foo:for-loop-finished");
additional_stuff(bar);

setTimeout(function(){
    console.log("3 second timeout");
    bar.remove_condition("foo:3-Second-Timer");
},3000);

JSFiddle 演示

于 2012-06-30T22:55:10.563 回答
2

如果您不想使用任何帮助程序库，而需要自己编写一些帮助程序，则没有简单的单行解决方案。

如果您想以看起来像在同步情况下一样可读的东西结束，请尝试一些延迟/承诺概念实现（它仍然是纯 JavaScript），例如使用deferred包您可能会得到一些简单的东西：

// Invoke one after another:
funcA()(funcB)(funcC);

// Invoke funcA and funcB simultaneously and afterwards funcC:
funcA()(funcB())(funcC);

// If want result of both funcA and funcB to be passed to funcC:
deferred(funcA(), funcB())(funcC);
于 2012-07-12T19:18:05.783 回答
0

看看 jQuery 的延迟对象。这提供了一种复杂的方法来控制在异步环境中发生的事情。

明显的用例是 AJAX，但不限于此。

资源：

于 2012-06-30T22:05:16.727 回答
0

我一直在寻找相同的模式。我正在使用查询多个远程数据源的 API。每个 API 都要求我向它们传递一个回调函数。这意味着我不能只触发一组我自己的函数并等待它们返回。相反，我需要一个与一组回调一起工作的解决方案，这些回调可能以任何顺序调用，具体取决于不同数据源的响应速度。

我想出了以下解决方案。JS 在我最熟悉的语言列表中排名靠后，所以这可能不是一个非常 JS 的习惯用法。

function getCallbackCreator( number_of_data_callbacks, final_callback ) {

    var all_data = {}

    return function ( data_key ) {

        return function( data_value ) {
            all_data[data_key] = data_value;

            if ( Object.keys(all_data).length == number_of_data_callbacks ) {
                final_callback( all_data );
            }
        }
    }
}

var getCallback = getCallbackCreator( 2, inflatePage );

myGoogleDataFetcher( getCallback( 'google' ) );
myCartoDataFetcher( getCallback( 'cartodb' ) );

编辑：这个问题被标记为 node.js 但 OP 说，“我正在为此寻找一个通用的 Javascript 编程模式”，所以即使我没有使用 node，我也已经发布了这个。

于 2015-09-29T14:59:19.503 回答
0

如今，人们可以这样做：

假设我们同时拥有 funcA、funcB 和 funcC：

如果希望将 funcA 和 funcB 结果传递给 funcC：

var promiseA = new Promise((resolve, reject) => {
  resolve(await funcA());
});
var promiseB = new Promise((resolve, reject) => {
  resolve(await funcB());
});
var promise = Promise.all([ promiseA, promiseB ]).then(results => {
  // results = [result from funcA, result from funcB]
  return funcC(results);
});

如果一个人想要 funcA，然后是 funcB，然后是 funcC：

var promise = (
  new Promise(async resolve => resolve( await funcA() ))
).then(result_a => funcB(result_a)).then(result_b => funcC(result_b));

最后：

promise.then(result_c => console.log('done.'));
于 2020-11-05T15:08:55.403 回答
-1 
how about:
funcC(funcB(funcA)));

我认为这些问题是因为某些函数运行时间更长，并且当 funcA 或 funcB 没有完成执行时，我们运行 funcC 时可能会出现这种情况。

于 2017-10-20T16:07:39.123 回答