streamline vs. callbacks bench

benchCallbacks.js

"use strict";
var fs = require('fs');
var cache = {}, hit = 0, missed = 0;

function load(name, cb) {
	var res = cache[name];
	if (res) {
		process.nextTick(function() {
			hit++;
			cb(null, res);
		});
	} else {
		fs.readFile(name, function(err, data) {
			missed++;
			cb(null, cache[name] = data);
		});
	}
}

var count = 1000000;

function bench(cb) {
	var total = 0;
	function loop(i) {
		if (i === count) {
			cb(null, total);
		} else {
			load(__dirname + '/benchCallbacks.js', function(err, data) {
				if (err) return cb(err);
				total += data.length;
				loop(i + 1);
			})
		}
	}
	loop(0);
}


var t0 = Date.now();
bench(function(err, result) {
	if (err) throw err;
	console.log('hit=' + hit + ', missed=' + missed + ', result=' + result);
	console.log('elapsed: ' + (Date.now() - t0));
});

benchCallbacks2.js

"use strict";
var fs = require('fs');
var cache = {}, hit = 0, missed = 0;

function load(name, cb) {
  var res = cache[name];
  if (res) {
    hit++;
    cb(null, res);
  } else {
    fs.readFile(name, function(err, data) {
      missed++;
      cb(null, cache[name] = data);
    });
  }
}

var count = 1000000;

function bench(cb) {
  var total = 0;
  function loop(i) {
    var async;
    while (async !== true) {
      async = undefined;
      if (i === count) {
        cb(null, total);
      } else {
        load(__dirname + '/benchCallbacks.js', function(err, data) {
          if (err) return cb(err);
          total += data.length;
          if (async) {
            loop(i + 1);
          } else {
            async = false;
            i++;
          }
        });
      }
      if (async !== false) {
        async = true;
      }
    }
  }
  loop(0);
}


var t0 = Date.now();
bench(function(err, result) {
  if (err) throw err;
  console.log('hit=' + hit + ', missed=' + missed + ', result=' + result);
  console.log('elapsed: ' + (Date.now() - t0));
});

benchStreamline._js

"use strict";
var fs = require('fs');
var cache = {}, hit = 0, missed = 0;

function load(name, _) {
	var res = cache[name];
	if (res) {
		hit++;
		return res;
	} else {
		missed++;
		return cache[name] = fs.readFile(name, _);
	}
}

var count = 1000000;

function bench(_) {
	var total = 0;
	for (var i = 0; i < count; i++) {
		var res = load(__dirname + '/benchCallbacks.js', _);
		total += res.length;
	}
	return total;
}

var t0 = Date.now();
var result = bench(_);
console.log('hit=' + hit + ', missed=' + missed + ', result=' + result);
console.log('elapsed: ' + (Date.now() - t0));