向各位前端工程师请教一道笔试题,有关JS并发处理异步任务的

const assert = require('assert');

/**
 * --- 问题描述 ---
 *
 * 给出一组异步任务方法,和允许同时执行的个数,实现一个方法,用于并发执行异步任务
 *
 * --- 说明 ---
 *
 * - 当有任务执行完毕后,自动补充任务,始终保持正在执行的任务有 `concurrency` 个
 * - 返回 { resolved: [], rejected: [] }
 *
 **/

async function parallel(tasks, concurrency) {

}

/*******测试部分*******/
module.exports = async function doTest() {
  try {
    const child_process = require('child_process');
    const fs = require('fs');
    const path = require('path');
    const util = require('util');
    const readFile = util.promisify(fs.readFile);
    const exec = util.promisify(child_process.exec);

    const tasks = [
      () => readFile(__filename, 'utf-8'),
      () => Promise.resolve('foo'),
      () => exec('npm -v'),
      () => readFile(path.join(__dirname, '../package.json'), 'utf-8'),
      () => process.cpuUsage(),
      () => exec('node -v'),
      () => Promise.reject(new Error('bar')),
      () => exec('ls -al'),
      () => new Promise(resolve => process.nextTick(resolve)),
      () => exec('whoami')
    ];
    const { resolved, rejected } = await parallel(tasks, 3);
    assert.equal(resolved.length, 9);
    assert.equal(rejected.length, 1);
    return '通过';
  } catch (err) {
    return '不通过';
  }
};

#笔经#
全部评论
这个问题解决了吗?前几天面试也碰到类似的了
点赞 回复 分享
发布于 2021-08-01 21:42
尝试一下,如有错误请大佬指正! async function parallel(tasks, n) {   const ans = {resolved: [], rejected: []};   const executing = new Set();   for (const task of tasks) {     const e = task().then(res => {       executing.delete(e);       ans.resolved.push(res);     }).catch(err => {       executing.delete(e);       ans.rejected.push(err);     });     executing.add(e);     if (executing.size >= n) {       await Promise.race(executing);     }   }   while (executing.size > 0) {     await Promise.race(executing);   }   return ans; }
点赞 回复 分享
发布于 2022-10-19 00:34 浙江

相关推荐

点赞 评论 收藏
分享
点赞 2 评论
分享
牛客网
牛客企业服务