369

考虑以下以串行/顺序方式读取文件数组的代码。readFiles返回一个承诺,只有在所有文件都按顺序读取后才会解决。

var readFile = function(file) {
  ... // Returns a promise.
};

var readFiles = function(files) {
  return new Promise((resolve, reject) => {
    var readSequential = function(index) {
      if (index >= files.length) {
        resolve();
      } else {
        readFile(files[index]).then(function() {
          readSequential(index + 1);
        }).catch(reject);
      }
    };

    readSequential(0); // Start with the first file!
  });
};

上面的代码有效,但我不喜欢为了顺序发生的事情而进行递归。有没有更简单的方法可以重写这段代码,这样我就不必使用我奇怪的readSequential函数了?

最初我尝试使用Promise.all,但这导致所有readFile调用同时发生,这不是我想要的:

var readFiles = function(files) {
  return Promise.all(files.map(function(file) {
    return readFile(file);
  }));
};
4

34 回答 34

450

2017 年更新:如果环境支持,我会使用异步函数:

async function readFiles(files) {
  for(const file of files) {
    await readFile(file);
  }
};

如果您愿意,您可以推迟读取文件,直到您需要使用异步生成器(如果您的环境支持它):

async function* readFiles(files) {
  for(const file of files) {
    yield await readFile(file);
  }
};

更新:再想一想 - 我可能会使用 for 循环:

var readFiles = function(files) {
  var p = Promise.resolve(); // Q() in q

  files.forEach(file =>
      p = p.then(() => readFile(file)); 
  );
  return p;
};

或者更紧凑,使用 reduce:

var readFiles = function(files) {
  return files.reduce((p, file) => {
     return p.then(() => readFile(file));
  }, Promise.resolve()); // initial
};

在其他 Promise 库(如 when 和 Bluebird)中,您有用于此目的的实用方法。

例如,蓝鸟将是:

var Promise = require("bluebird");
var fs = Promise.promisifyAll(require("fs"));

var readAll = Promise.resolve(files).map(fs.readFileAsync,{concurrency: 1 });
// if the order matters, you can use Promise.each instead and omit concurrency param

readAll.then(function(allFileContents){
    // do stuff to read files.
});

尽管今天确实没有理由使用 async await。

于 2014-07-05T11:55:26.607 回答
84

这是我更喜欢串行运行任务的方式。

function runSerial() {
    var that = this;
    // task1 is a function that returns a promise (and immediately starts executing)
    // task2 is a function that returns a promise (and immediately starts executing)
    return Promise.resolve()
        .then(function() {
            return that.task1();
        })
        .then(function() {
            return that.task2();
        })
        .then(function() {
            console.log(" ---- done ----");
        });
}

任务较多的案例呢?比如,10?

function runSerial(tasks) {
  var result = Promise.resolve();
  tasks.forEach(task => {
    result = result.then(() => task());
  });
  return result;
}
于 2015-06-26T09:54:04.793 回答
81

这个问题很老了,但我们生活在一个 ES6 和函数式 JavaScript 的世界里,所以让我们看看如何改进。

因为 Promise 会立即执行,所以我们不能只创建一个 Promise 数组,它们都会并行触发。

相反,我们需要创建一个返回 Promise 的函数数组。然后每个函数将按顺序执行,然后在内部启动 Promise。

我们可以通过几种方式解决这个问题,但我最喜欢的方式是使用reduce.

与 promises 结合使用会有点棘手reduce,所以我将一个衬里分解为下面一些较小的易消化部分。

此函数的本质是使用reduce从 的初始值Promise.resolve([])或包含空数组的 Promise 开始。

然后,此承诺将reduce作为promise. 这是将每个承诺按顺序链接在一起的关键。下一个要执行的 Promise 是func,当then触发时,结果被连接起来,然后返回该reducePromise,使用下一个 Promise 函数执行循环。

一旦所有的 Promise 都执行完毕,返回的 Promise 将包含每个 Promise 的所有结果的数组。

ES6 示例(一行)

/*
 * serial executes Promises sequentially.
 * @param {funcs} An array of funcs that return promises.
 * @example
 * const urls = ['/url1', '/url2', '/url3']
 * serial(urls.map(url => () => $.ajax(url)))
 *     .then(console.log.bind(console))
 */
const serial = funcs =>
    funcs.reduce((promise, func) =>
        promise.then(result => func().then(Array.prototype.concat.bind(result))), Promise.resolve([]))

ES6 示例(分解)

// broken down to for easier understanding

const concat = list => Array.prototype.concat.bind(list)
const promiseConcat = f => x => f().then(concat(x))
const promiseReduce = (acc, x) => acc.then(promiseConcat(x))
/*
 * serial executes Promises sequentially.
 * @param {funcs} An array of funcs that return promises.
 * @example
 * const urls = ['/url1', '/url2', '/url3']
 * serial(urls.map(url => () => $.ajax(url)))
 *     .then(console.log.bind(console))
 */
const serial = funcs => funcs.reduce(promiseReduce, Promise.resolve([]))

用法:

// first take your work
const urls = ['/url1', '/url2', '/url3', '/url4']

// next convert each item to a function that returns a promise
const funcs = urls.map(url => () => $.ajax(url))

// execute them serially
serial(funcs)
    .then(console.log.bind(console))
于 2016-12-13T06:44:59.810 回答
50

要在 ES6 中简单地做到这一点:

function(files) {
  // Create a new empty promise (don't do that with real people ;)
  var sequence = Promise.resolve();

  // Loop over each file, and add on a promise to the
  // end of the 'sequence' promise.
  files.forEach(file => {

    // Chain one computation onto the sequence
    sequence = 
      sequence
        .then(() => performComputation(file))
        .then(result => doSomething(result)); 
        // Resolves for each file, one at a time.

  })

  // This will resolve after the entire chain is resolved
  return sequence;
}
于 2016-04-17T02:26:09.130 回答
32

加法示例

const addTwo = async () => 2;

const addThree = async (inValue) => new Promise((resolve) => setTimeout(resolve(inValue + 3), 2000));

const addFour = (inValue) => new Promise((res) => setTimeout(res(inValue + 4), 1000)); 

const addFive = async (inValue) => inValue + 5;

// Function which handles promises from above
async function sequenceAddition() {
  let sum = await [addTwo, addThree, addFour, addFive].reduce(
    (promise, currPromise) => promise.then((val) => currPromise(val)),
    Promise.resolve()
  );
  console.log('sum:', sum); // 2 + 3 + 4 + 5 =  14
}

// Run function. See console for result.
sequenceAddition();

使用的一般语法reduce()

function sequence(tasks, fn) {
    return tasks.reduce((promise, task) => promise.then(() => fn(task)), Promise.resolve());
}

更新

items-promise是一个现成的 NPM 包,它做同样的事情。

于 2017-02-19T08:00:09.380 回答
12

我不得不运行很多顺序任务并使用这些答案来打造一个可以处理任何顺序任务的函数......

function one_by_one(objects_array, iterator, callback) {
    var start_promise = objects_array.reduce(function (prom, object) {
        return prom.then(function () {
            return iterator(object);
        });
    }, Promise.resolve()); // initial
    if(callback){
        start_promise.then(callback);
    }else{
        return start_promise;
    }
}

该函数接受 2 个参数 + 1 个可选参数。第一个参数是我们将要处理的数组。第二个参数是任务本身,一个返回一个promise的函数,只有当这个promise解决时,下一个任务才会启动。第三个参数是所有任务完成后运行的回调。如果没有传递回调,则该函数返回它创建的承诺,以便我们可以处理结束。

这是一个使用示例:

var filenames = ['1.jpg','2.jpg','3.jpg'];
var resize_task = function(filename){
    //return promise of async resizing with filename
};
one_by_one(filenames,resize_task );

希望它可以节省一些时间...

于 2016-07-13T19:30:31.523 回答
6

我能想到的最好的解决方案是bluebird承诺。你可以这样做Promise.resolve(files).each(fs.readFileAsync);保证承诺按顺序解决。

于 2015-05-06T07:32:01.073 回答
6

我的首选解决方案:

function processArray(arr, fn) {
    return arr.reduce(
        (p, v) => p.then((a) => fn(v).then(r => a.concat([r]))),
        Promise.resolve([])
    );
}

它与此处发布的其他内容没有根本不同,但是:

  • 将函数应用于系列项目
  • 解析为结果数组
  • 不需要 async/await(支持仍然非常有限,大约 2017 年)
  • 使用箭头函数;简洁明了

示例用法:

const numbers = [0, 4, 20, 100];
const multiplyBy3 = (x) => new Promise(res => res(x * 3));

// Prints [ 0, 12, 60, 300 ]
processArray(numbers, multiplyBy3).then(console.log);

在合理的当前 Chrome (v59) 和 NodeJS (v8.1.2) 上测试。

于 2017-08-01T04:51:25.210 回答
5

这是上面另一个答案的轻微变化。使用原生 Promise:

function inSequence(tasks) {
    return tasks.reduce((p, task) => p.then(task), Promise.resolve())
}

解释

如果你有这些任务[t1, t2, t3],那么上面就相当于Promise.resolve().then(t1).then(t2).then(t3)。这是减少的行为。

如何使用

首先,您需要构建一个任务列表!任务是不接受任何参数的函数。如果您需要将参数传递给您的函数,请使用bind或其他方法来创建任务。例如:

var tasks = files.map(file => processFile.bind(null, file))
inSequence(tasks).then(...)
于 2017-07-10T22:21:48.750 回答
5

首先,您需要了解承诺是在创建时执行的。
因此,例如,如果您有代码:

["a","b","c"].map(x => returnsPromise(x))

您需要将其更改为:

["a","b","c"].map(x => () => returnsPromise(x))

然后我们需要顺序链接承诺:

["a", "b", "c"].map(x => () => returnsPromise(x))
    .reduce(
        (before, after) => before.then(_ => after()),
        Promise.resolve()
    )

execution after(),将确保仅在时机成熟时才创建(并执行)promise。

于 2019-12-23T10:43:49.363 回答
4

使用 ES2016 的 async/await(可能还有 ES2018 的一些特性),这可以简化为这种形式:

function readFile(file) {
  ... // Returns a promise.
}

async function readFiles(files) {
  for (file in files) {
     await readFile(file)
  }
}

我还没有看到另一个答案表达了这种简单性。OP 表示不需要并行执行 readFile。但是,对于这样的 IO,在读取单个文件时不阻塞确实很有意义,同时保持循环执行同步(在读取所有文件之前,您不希望执行下一步)。由于我刚刚了解到这一点并且对此感到有些兴奋,因此我将分享 readFile 的并行异步执行与 readFiles 的整体同步执行的方法。

async function readFiles(files) {
  await Promise.all(files.map(readFile))
}

这不是美的东西吗?

于 2021-02-08T17:44:56.213 回答
4

使用 Async/Await(如果你有 ES7 的支持)

function downloadFile(fileUrl) { ... } // This function return a Promise

async function main()
{
  var filesList = [...];

  for (const file of filesList) {
    await downloadFile(file);
  }
}

(你必须使用for循环,而不是forEach因为 async/await 在 forEach 循环中运行有问题)

没有 Async/Await(使用 Promise)

function downloadFile(fileUrl) { ... } // This function return a Promise

function downloadRecursion(filesList, index)
{
  index = index || 0;
  if (index < filesList.length)
  {
    downloadFile(filesList[index]).then(function()
    {
      index++;
      downloadRecursion(filesList, index); // self invocation - recursion!
    });
  }
  else
  {
    return Promise.resolve();
  }
}

function main()
{
  var filesList = [...];
  downloadRecursion(filesList);
}
于 2018-10-29T17:00:01.553 回答
3

使用Array.prototype.reduce,并记住将你的 Promise 包装在一个函数中,否则它们已经在运行了!

// array of Promise providers

const providers = [
  function(){
     return Promise.resolve(1);
  },
  function(){
     return Promise.resolve(2);
  },
  function(){
     return Promise.resolve(3);
  }
]


const inSeries = function(providers){

  const seed = Promise.resolve(null); 

  return providers.reduce(function(a,b){
      return a.then(b);
  }, seed);
};

又好又简单...您应该能够重复使用相同的种子来提高性能等。

使用 reduce 时,防止空数组或只有 1 个元素的数组很重要,所以这种技术是你最好的选择:

   const providers = [
      function(v){
         return Promise.resolve(v+1);
      },
      function(v){
         return Promise.resolve(v+2);
      },
      function(v){
         return Promise.resolve(v+3);
      }
    ]

    const inSeries = function(providers, initialVal){

        if(providers.length < 1){
            return Promise.resolve(null)
        }

        return providers.reduce((a,b) => a.then(b), providers.shift()(initialVal));
    };

然后像这样称呼它:

inSeries(providers, 1).then(v => {
   console.log(v);  // 7
});
于 2017-12-12T19:42:02.990 回答
3

我的回答基于https://stackoverflow.com/a/31070150/7542429

Promise.series = function series(arrayOfPromises) {
    var results = [];
    return arrayOfPromises.reduce(function(seriesPromise, promise) {
      return seriesPromise.then(function() {
        return promise
        .then(function(result) {
          results.push(result);
        });
      });
    }, Promise.resolve())
    .then(function() {
      return results;
    });
  };

此解决方案将结果作为数组返回,例如 Promise.all()。

用法:

Promise.series([array of promises])
.then(function(results) { 
  // do stuff with results here
});
于 2017-04-12T19:01:28.290 回答
3

大多数答案不单独包括所有承诺的结果,因此如果有人正在寻找这种特定行为,这是使用递归的可能解决方案。

它遵循以下风格Promise.all

  • .then()回调中返回结果数组。

  • 如果某个 promise 失败,它会立即在.catch()回调中返回。

const promiseEach = (arrayOfTasks) => {
  let results = []
  return new Promise((resolve, reject) => {
    const resolveNext = (arrayOfTasks) => {
      // If all tasks are already resolved, return the final array of results
      if (arrayOfTasks.length === 0) return resolve(results)

      // Extract first promise and solve it
      const first = arrayOfTasks.shift()

      first().then((res) => {
        results.push(res)
        resolveNext(arrayOfTasks)
      }).catch((err) => {
        reject(err)
      })
    }
    resolveNext(arrayOfTasks)
  })
}

// Lets try it 

const promise = (time, shouldThrowError) => new Promise((resolve, reject) => {
  const timeInMs = time * 1000
  setTimeout(()=>{
    console.log(`Waited ${time} secs`)
    if (shouldThrowError) reject(new Error('Promise failed'))
    resolve(time)
  }, timeInMs)
})

const tasks = [() => promise(1), () => promise(2)]

promiseEach(tasks)
  .then((res) => {
    console.log(res) // [1, 2]
  })
  // Oops some promise failed
  .catch((error) => {
    console.log(error)
  })

关于tasks数组声明的注意事项:

在这种情况下,不可能像使用以下符号一样Promise.all使用:

const tasks = [promise(1), promise(2)]

我们必须使用:

const tasks = [() => promise(1), () => promise(2)]

原因是 JavaScript 在声明后立即开始执行承诺。如果我们使用类似的方法Promise.all,它只是检查它们的状态是否为fulfilledor rejected,但不会启动执行本身。使用() => promise()我们停止执行,直到它被调用。

于 2020-01-26T14:23:28.353 回答
3

我在 Promise 对象上创建了这个简单的方法:

创建 Promise.sequence 方法并将其添加到 Promise 对象

Promise.sequence = function (chain) {
    var results = [];
    var entries = chain;
    if (entries.entries) entries = entries.entries();
    return new Promise(function (yes, no) {
        var next = function () {
            var entry = entries.next();
            if(entry.done) yes(results);
            else {
                results.push(entry.value[1]().then(next, function() { no(results); } ));
            }
        };
        next();
    });
};

用法:

var todo = [];

todo.push(firstPromise);
if (someCriterium) todo.push(optionalPromise);
todo.push(lastPromise);

// Invoking them
Promise.sequence(todo)
    .then(function(results) {}, function(results) {});

这个对 Promise 对象的扩展最好的地方在于它与 Promise 的风格一致。Promise.all 和 Promise.sequence 调用方式相同,但语义不同。

警告

Promise 的顺序运行通常不是使用 Promise 的好方法。通常最好使用 Promise.all,并让浏览器尽可能快地运行代码。然而,它也有真实的用例——例如在使用 javascript 编写移动应用程序时。

于 2015-07-29T12:32:33.230 回答
2

使用现代 ES:

const series = async (tasks) => {
  const results = [];

  for (const task of tasks) {
    const result = await task;

    results.push(result);
  }

  return results;
};

//...

const readFiles = await series(files.map(readFile));
于 2019-11-19T11:20:56.943 回答
2

您可以使用此函数获取 promiseFactories 列表:

function executeSequentially(promiseFactories) {
    var result = Promise.resolve();
    promiseFactories.forEach(function (promiseFactory) {
        result = result.then(promiseFactory);
    });
    return result;
}

Promise Factory 只是一个返回 Promise 的简单函数:

function myPromiseFactory() {
    return somethingThatCreatesAPromise();
}

它之所以有效,是因为 Promise 工厂在被要求之前不会创建 Promise。它的工作方式与 then 函数相同——事实上,它是一回事!

您根本不想对一系列承诺进行操作。根据 Promise 规范,一旦创建了 Promise,它就会开始执行。所以你真正想要的是一系列承诺工厂......

如果您想了解有关 Promises 的更多信息,请查看此链接: https ://pouchdb.com/2015/05/18/we-have-a-problem-with-promises.html

于 2016-12-22T16:24:33.623 回答
2

正如 Bergi 所注意到的,我认为最好和明确的解决方案是使用 BlueBird.each,代码如下:

const BlueBird = require('bluebird');
BlueBird.each(files, fs.readFileAsync);
于 2018-11-18T15:41:26.913 回答
2

我真的很喜欢@joelnet 的回答,但对我来说,这种编码风格有点难以消化,所以我花了几天时间试图弄清楚如何以更易读的方式表达相同的解决方案,这是我的采取,只是使用不同的语法和一些注释。

// first take your work
const urls = ['/url1', '/url2', '/url3', '/url4']

// next convert each item to a function that returns a promise
const functions = urls.map((url) => {
  // For every url we return a new function
  return () => {
    return new Promise((resolve) => {
      // random wait in milliseconds
      const randomWait = parseInt((Math.random() * 1000),10)
      console.log('waiting to resolve in ms', randomWait)
      setTimeout(()=>resolve({randomWait, url}),randomWait)
    })
  }
})


const promiseReduce = (acc, next) => {
  // we wait for the accumulator to resolve it's promise
  return acc.then((accResult) => {
    // and then we return a new promise that will become
    // the new value for the accumulator
    return next().then((nextResult) => {
      // that eventually will resolve to a new array containing
      // the value of the two promises
      return accResult.concat(nextResult)
    })
  })
};
// the accumulator will always be a promise that resolves to an array
const accumulator = Promise.resolve([])

// we call reduce with the reduce function and the accumulator initial value
functions.reduce(promiseReduce, accumulator)
  .then((result) => {
    // let's display the final value here
    console.log('=== The final result ===')
    console.log(result)
  })
于 2017-08-29T16:15:25.177 回答
2

如果您愿意,可以使用 reduce 来做出顺序承诺,例如:

[2,3,4,5,6,7,8,9].reduce((promises, page) => {
    return promises.then((page) => {
        console.log(page);
        return Promise.resolve(page+1);
    });
  }, Promise.resolve(1));

它总是按顺序工作。

于 2017-02-10T15:34:16.680 回答
1

这是我sequentially在各种项目中使用的实现:

const file = [file1, file2, file3];
const fileContents = sequentially(readFile, files);

// somewhere else in the code:

export const sequentially = async <T, P>(
  toPromise: (element: T) => Promise<P>,
  elements: T[]
): Promise<P[]> => {
  const results: P[] = [];
  await elements.reduce(async (sequence, element) => {
    await sequence;
    results.push(await toPromise(element));
  }, Promise.resolve());

  return results;
};

于 2021-07-30T12:19:49.860 回答
1

我使用以下代码来扩展 Promise 对象。它处理对承诺的拒绝并返回结果数组

代码

/*
    Runs tasks in sequence and resolves a promise upon finish

    tasks: an array of functions that return a promise upon call.
    parameters: an array of arrays corresponding to the parameters to be passed on each function call.
    context: Object to use as context to call each function. (The 'this' keyword that may be used inside the function definition)
*/
Promise.sequence = function(tasks, parameters = [], context = null) {
    return new Promise((resolve, reject)=>{

        var nextTask = tasks.splice(0,1)[0].apply(context, parameters[0]); //Dequeue and call the first task
        var output = new Array(tasks.length + 1);
        var errorFlag = false;

        tasks.forEach((task, index) => {
            nextTask = nextTask.then(r => {
                output[index] = r;
                return task.apply(context, parameters[index+1]);
            }, e=>{
                output[index] = e;
                errorFlag = true;
                return task.apply(context, parameters[index+1]);
            });
        });

        // Last task
        nextTask.then(r=>{
            output[output.length - 1] = r;
            if (errorFlag) reject(output); else resolve(output);
        })
        .catch(e=>{
            output[output.length - 1] = e;
            reject(output);
        });
    });
};

例子

function functionThatReturnsAPromise(n) {
    return new Promise((resolve, reject)=>{
        //Emulating real life delays, like a web request
        setTimeout(()=>{
            resolve(n);
        }, 1000);
    });
}

var arrayOfArguments = [['a'],['b'],['c'],['d']];
var arrayOfFunctions = (new Array(4)).fill(functionThatReturnsAPromise);


Promise.sequence(arrayOfFunctions, arrayOfArguments)
.then(console.log)
.catch(console.error);
于 2017-01-04T05:30:49.910 回答
0

数组 push 和 pop 方法可用于 promise 序列。当您需要更多数据时,您还可以推送新的承诺。这是代码,我将在 React Infinite 加载器中使用来加载页面序列。

var promises = [Promise.resolve()];

function methodThatReturnsAPromise(page) {
	return new Promise((resolve, reject) => {
		setTimeout(() => {
			console.log(`Resolve-${page}! ${new Date()} `);
			resolve();
		}, 1000);
	});
}

function pushPromise(page) {
	promises.push(promises.pop().then(function () {
		return methodThatReturnsAPromise(page)
	}));
}

pushPromise(1);
pushPromise(2);
pushPromise(3);

于 2019-05-12T13:13:11.867 回答
0

根据问题的标题“一个接一个地解决承诺(即按顺序)?”,我们可能会理解,OP 对结算承诺的顺序处理比顺序调用本身更感兴趣。

提供了这个答案:

  • 证明顺序调用对于顺序处理响应不是必需的。
  • 向该页面的访问者展示可行的替代模式 - 如果一年后他仍然感兴趣,包括 OP。
  • 尽管 OP 声称他不想同时拨打电话,这可能确实是这种情况,但同样可能是基于标题所暗示的顺序处理响应的愿望的假设。

如果确实不需要并发呼叫,那么请参阅 Benjamin Gruenbaum 的回答,其中全面涵盖了顺序呼叫(等)。

但是,如果您对允许并发调用然后按顺序处理响应的模式感兴趣(为了提高性能),请继续阅读。

很容易认为您必须使用Promise.all(arr.map(fn)).then(fn)(就像我多次做过的那样)或 Promise lib 的花哨的糖(尤其是 Bluebird 的),但是(感谢本文)一个arr.map(fn).reduce(fn)模式可以完成这项工作,它具有以下优点:

  • 仅适用于任何 Promise 库——甚至是 jQuery 的预兼容版本.then()
  • 提供了跳过错误或停止错误的灵活性,无论您想要使用单行模式。

在这里,为Q.

var readFiles = function(files) {
    return files.map(readFile) //Make calls in parallel.
    .reduce(function(sequence, filePromise) {
        return sequence.then(function() {
            return filePromise;
        }).then(function(file) {
            //Do stuff with file ... in the correct sequence!
        }, function(error) {
            console.log(error); //optional
            return sequence;//skip-over-error. To stop-on-error, `return error` (jQuery), or `throw  error` (Promises/A+).
        });
    }, Q()).then(function() {
        // all done.
    });
};

注意:只有一个片段,Q(),是特定于 Q 的。对于 jQuery,您需要确保 readFile() 返回一个 jQuery 承诺。使用 A+ 库,外国承诺将被同化。

这里的关键是reduction 的promise,它对promise 的处理进行sequence排序,而不是对它们的创建进行排序。readFile

一旦你吸收了这一点,当你意识到这个.map()舞台实际上并不是必需的时,它可能会有点令人兴奋!整个工作,并行调用加上正确顺序的串行处理,可以reduce()单独完成,加上进一步灵活性的附加优势:

  • 只需移动一行即可从并行异步调用转换为串行异步调用 - 在开发过程中可能很有用。

在这里,Q再次。

var readFiles = function(files) {
    return files.reduce(function(sequence, f) {
        var filePromise = readFile(f);//Make calls in parallel. To call sequentially, move this line down one.
        return sequence.then(function() {
            return filePromise;
        }).then(function(file) {
            //Do stuff with file ... in the correct sequence!
        }, function(error) {
            console.log(error); //optional
            return sequence;//Skip over any errors. To stop-on-error, `return error` (jQuery), or `throw  error` (Promises/A+).
        });
    }, Q()).then(function() {
        // all done.
    });
};

这就是基本模式。如果您还想将数据(例如文件或它们的某些转换)传递给调用者,则需要一个温和的变体。

于 2015-09-09T01:47:21.373 回答
0

您的方法还不错,但它确实有两个问题:它会吞下错误,并且它采用了 Explicit Promise Construction Antipattern。

您可以解决这两个问题,并使代码更简洁,同时仍采用相同的一般策略:

var Q = require("q");

var readFile = function(file) {
  ... // Returns a promise.
};

var readFiles = function(files) {
  var readSequential = function(index) {
    if (index < files.length) {
      return readFile(files[index]).then(function() {
        return readSequential(index + 1);
      });
    }
  };

  // using Promise.resolve() here in case files.length is 0
  return Promise.resolve(readSequential(0)); // Start!
};
于 2017-03-30T11:13:41.190 回答
0

有一个 npm 包Promise Serial可以很好地做到这一点:

const Promise_serial = require('promise-serial');

 const promises =
    Array(15).fill()
    .map((_, i) =>
        () => new Promise(resolve => {
            console.log('promise '+i+' start');
            setTimeout(
                () => {
                    console.log('promise '+i+' end');
                    resolve('output-'+i);
                },
                500
            );
        })
    );


console.log('### Run promises in sequence')

Promise_serial(promises)

输出:

promise 0 start
promise 0 end
promise 1 start
promise 1 end
promise 2 start
promise 2 end
promise 3 start
promise 3 end
promise 4 start
promise 4 end
promise 5 start
promise 5 end
promise 6 start
promise 6 end
promise 7 start
promise 7 end

... etc

您还可以对它们进行批处理或并行化。

见:https ://www.npmjs.com/package/promise-serial

于 2021-10-22T05:23:09.700 回答
0

如果其他人在执行 CRUD 操作时需要一种有保证的 STRICTLY 顺序解决 Promise 的方式,您也可以使用以下代码作为基础。

只要您在调用每个函数之前添加“return”,描述一个 Promise,并以此示例为基础,下一个 .then() 函数调用将始终在前一个函数完成后开始:

getRidOfOlderShoutsPromise = () => {
    return readShoutsPromise('BEFORE')
    .then(() => {
        return deleteOlderShoutsPromise();
    })
    .then(() => {
        return readShoutsPromise('AFTER')
    })
    .catch(err => console.log(err.message));
}

deleteOlderShoutsPromise = () => {
    return new Promise ( (resolve, reject) => {
        console.log("in deleteOlderShouts");
        let d = new Date();
        let TwoMinuteAgo = d - 1000 * 90 ;
        All_Shouts.deleteMany({ dateTime: {$lt: TwoMinuteAgo}}, function(err) {
            if (err) reject();
            console.log("DELETED OLDs at "+d);
            resolve();        
        });
    });
}

readShoutsPromise = (tex) => {
    return new Promise( (resolve, reject) => {
        console.log("in readShoutsPromise -"+tex);
        All_Shouts
        .find({})
        .sort([['dateTime', 'ascending']])
        .exec(function (err, data){
            if (err) reject();
            let d = new Date();
            console.log("shouts "+tex+" delete PROMISE = "+data.length +"; date ="+d);
            resolve(data);
        });    
    });
}
于 2018-06-21T14:46:27.197 回答
0

只需使用 .then(resPrevTask => nextTask())

(顺便说一句,下一个代码需要 4 秒。)

function task1() {
    return new Promise((resolve) => {
        setTimeout(() => {
            resolve(console.log("task 1"))
        }, 3000)
    })
}

function task2() {
    return new Promise((resolve) => {
        setTimeout(() => {
            resolve(console.log("task 2"))
        }, 1000)
    })
}

function seqTasks(){
    task1()
    .then(() => task2())
}

seqTasks();

于 2022-01-22T23:16:32.273 回答
0

创建一个 Promise 数组以插入到 Promise.all 中,除了 - 而不是传入 Promise 数组;遍历 promise 数组并返回 Promise.all。

这本质上按顺序解析每个承诺,并且隐含的返回将在映射数组中返回解析的值。

我没有对此进行测试,但它可能需要一些调整,但总体思路是这将按顺序解决每个承诺。

const files = [];
const filesPromise = [];
const readFiles = () => {
   // returns promise
}

const processFiles = async() => {
   files.forEach(item => filesPromise.push(readFiles(item));
   
   return filesPromise.map(item =>{
      const results = await Promise.all([item]);
      return results;
   });
}

const arrayOfResults = processFiles();
于 2022-02-18T04:46:29.173 回答
0

promise-sequence在nodejs中有。

const promiseSequence = require('promise-sequence');
return promiseSequence(arr.map(el => () => doPromise(el)));
于 2021-01-06T14:31:51.907 回答
0
(function() {
  function sleep(ms) {
    return new Promise(function(resolve) {
      setTimeout(function() {
        return resolve();
      }, ms);
    });
  }

  function serial(arr, index, results) {
    if (index == arr.length) {
      return Promise.resolve(results);
    }
    return new Promise(function(resolve, reject) {
      if (!index) {
        index = 0;
        results = [];
      }
      return arr[index]()
        .then(function(d) {
          return resolve(d);
        })
        .catch(function(err) {
          return reject(err);
        });
    })
      .then(function(result) {
        console.log("here");
        results.push(result);
        return serial(arr, index + 1, results);
      })
      .catch(function(err) {
        throw err;
      });
  }

  const a = [5000, 5000, 5000];

  serial(a.map(x => () => sleep(x)));
})();

这里的关键是如何调用 sleep 函数。您需要传递一个函数数组,这些函数本身返回一个 Promise 而不是 Promise 数组。

于 2020-02-26T17:04:12.587 回答
-1

这里有很多答案,但我没有看到这个简单的解决方案:

await array.reduce(
  async (promise, member) => await myLongSequentialPromise(member),
  array[0]
)

证明:https ://jsbin.com/nulafus/1/edit?js,console

于 2019-02-27T23:29:54.660 回答
-1

这是为了扩展如何以更通用的方式处理一系列承诺,支持动态/无限序列,基于spex.sequence实现:

var $q = require("q");
var spex = require('spex')($q);

var files = []; // any dynamic source of files;

var readFile = function (file) {
    // returns a promise;
};

function source(index) {
    if (index < files.length) {
        return readFile(files[index]);
    }
}

function dest(index, data) {
    // data = resolved data from readFile;
}

spex.sequence(source, dest)
    .then(function (data) {
        // finished the sequence;
    })
    .catch(function (error) {
        // error;
    });

此解决方案不仅适用于任何大小的序列,而且您可以轻松地为其添加数据限制和负载平衡

于 2015-10-28T18:01:02.923 回答