var _ = require("lodash");
var tasks;

module.exports = [
  {
      name: "each",
      // args lists are passed to the setup function
      args: [[10], [300], [10000]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.each(tasks, function (num, cb) {
              async.setImmediate(cb);
          }, done);
      }
  },
  {
      name: "eachSeries",
      args: [[10], [300], [10000]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.eachSeries(tasks, function (num, cb) {
              async.setImmediate(cb);
          }, done);
      }
  },
  {
      name: "eachLimit",
      args: [[10], [300], [10000]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.eachLimit(tasks, 4, function (num, cb) {
              async.setImmediate(cb);
          }, done);
      }
  },
  {
      name: "map",
      // args lists are passed to the setup function
      args: [[10], [300], [10000]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.map(tasks, function (num, cb) {
              async.setImmediate(cb);
          }, done);
      }
  },
  {
      name: "mapSeries",
      args: [[10], [300], [10000]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.mapSeries(tasks, function (num, cb) {
              async.setImmediate(cb);
          }, done);
      }
  },
  {
      name: "mapLimit",
      args: [[10], [300], [10000]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.mapLimit(tasks, 4, function (num, cb) {
              async.setImmediate(cb);
          }, done);
      }
  },
  {
      name: "eachOf",
      // args lists are passed to the setup function
      args: [[10], [300], [10000]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.eachOf(tasks, function (num, i, cb) {
              async.setImmediate(cb);
          }, done);
      }
  },
  {
      name: "eachOfSeries",
      args: [[10], [300], [10000]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.eachOfSeries(tasks, function (num, i, cb) {
              async.setImmediate(cb);
          }, done);
      }
  },
  {
      name: "eachOfLimit",
      args: [[10], [300], [10000]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.eachOfLimit(tasks, 4, function (num, i, cb) {
              async.setImmediate(cb);
          }, done);
      }
  },
  {
      name: "parallel",
      args: [[10], [100], [1000]],
      setup: function (count) {
          tasks = _.range(count).map(function () {
              return function (cb) {
                  setImmediate(cb);
              };
          });
      },
      fn: function (async, done) {
          async.parallel(tasks, done);
      }
  },
  {
      name: "series",
      args: [[10], [100], [1000]],
      setup: function (count) {
          tasks = _.range(count).map(function () {
              return function (cb) { setImmediate(cb); };
          });
      },
      fn: function (async, done) {
          async.series(tasks, done);
      }
  },
  {
      name: "waterfall",
      args: [[10], [100], [1000]],
      setup: function (count) {
          tasks = [
          function (cb) {
              return cb(null, 1);
          }
        ].concat(_.range(count).map(function (i) {
            return function (arg, cb) {
                setImmediate(function () {
                    cb(null, i);
                });
            };
        }));
      },
      fn: function (async, done) {
          async.waterfall(tasks, done);
      }
  },
  {
      name: "queue",
      args: [[1000], [30000], [100000], [200000]],
      setup: function (count) {
          tasks = count;
      },
      fn: function (async, done) {
          var numEntries = tasks;
          var q = async.queue(worker, 1);
          for (var i = 1; i <= numEntries; i++) {
              q.push({num: i});
          }
          function worker(task, callback) {
              if (task.num === numEntries) {
                  return done();
              }
              setImmediate(callback);
          }
      }
  },
  {
      name: "some - no short circuit- false",
      // args lists are passed to the setup function
      args: [[500]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.some(tasks, function(i, cb) {
              async.setImmediate(function() {
                  cb(i >= 600);
              });
          }, done);
      }
  },
  {
      name: "some - short circuit - true",
      // args lists are passed to the setup function
      args: [[500]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.some(tasks, function(i, cb) {
              async.setImmediate(function() {
                  cb(i >= 60);
              });
          }, done);
      }
  },
  {
      name: "every - no short circuit- true",
      // args lists are passed to the setup function
      args: [[500]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.every(tasks, function(i, cb) {
              async.setImmediate(function() {
                  cb(i <= 600);
              });
          }, done);
      }
  },
  {
      name: "every - short circuit - false",
      // args lists are passed to the setup function
      args: [[500]],
      setup: function(count) {
          tasks = _.range(count);
      },
      fn: function (async, done) {
          async.every(tasks, function(i, cb) {
              async.setImmediate(function() {
                  cb(i <= 60);
              });
          }, done);
      }
  },
  {
      name: "defer nextTick",
      fn: function (async, done) {
          process.nextTick(done);
      }
  },
  {
      name: "defer setImmediate",
      fn: function (async, done) {
          setImmediate(done);
      }
  },
  {
      name: "defer async.nextTick",
      fn: function (async, done) {
          async.nextTick(done);
      }
  },
  {
      name: "defer async.setImmediate",
      fn: function (async, done) {
          async.setImmediate(done);
      }
  },
  {
      name: "defer setTimeout",
      fn: function (async, done) {
          setTimeout(done, 0);
      }
  },
  {
      name: "ensureAsync sync",
      fn: function (async, done) {
          async.ensureAsync(function (cb) {
              cb();
          })(done);
      }
  },
  {
      name: "ensureAsync async",
      fn: function (async, done) {
          async.ensureAsync(function (cb) {
              setImmediate(cb);
          })(done);
      }
  },
  {
      name: "ensureAsync async noWrap",
      fn: function (async, done) {
          (function (cb) {
              setImmediate(cb);
          }(done));
      }
  }
];