第七周作业总结

#!/usr/bin/env node
const program = require('commander');
const axios = require('axios');
program
  .option('--url, <value>', 'url')
  .option('--con, <value>', 'concurrence')
  .option('--number, <value>', 'total number');
program.parse(process.argv);
function SimpleQueue() {
  let queue = [];
  let currentJobs = [];
  return {
    push: item => {
      queue.push(item);
    },
    start: (con, handler, done) => {
      function run() {
        if (!queue.length && !currentJobs.length) {
          done();
        } else if (currentJobs.length < con) {
          if (queue.length) {
            for (let i = 0; i < con - currentJobs.length; i++) {
              currentJobs.push(queue.shift());
            }
          }
          currentJobs
            .filter(item => !!item)
            .filter(item => {
              return !item.__started;
            })
            .forEach((item, index) => {
              item.__started = true;
              handler(item).then(() => {
                currentJobs.splice(index, 1);
                run();
              });
            });
        }
      }
      run();
    },
  };
}
const queue = SimpleQueue();
const con = parseInt(program.con);
const number = parseInt(program.number);
for (let i = 0; i < number; i++) {
  queue.push({
    url: program.url,
  });
}
let results = [];
queue.start(
  con,
  item => {
    const currentTime = Date.now();
    return axios
      .get(item.url)
      .then(() => {
        results.push(Date.now() - currentTime);
      })
      .catch(err => {
        console.log('err');
      });
  },
  () => {
    console.log('done', results);
    console.log(
      'AVG: ',
      results.reduce((acc, cur) => {
        return acc + cur;
      }, 0) / number
    );
    console.log('95:', results.sort()[94]);
  }
);