fibers-synchronization.js

var Future = require('fibers/future');

function Lock() {
	this.futures = [];
}
Lock.prototype.enter = function() {
	this.futures.push(new Future);
	if (this.futures.length > 1) {
		this.futures[this.futures.length - 2].wait();
	}
}
Lock.prototype.exit = function() {
	var future = this.futures.shift();
	process.nextTick(future.return.bind(future));
}

function Synchronized(func) {
	var lock = new Lock;
	return function() {
		lock.enter();
		try {
			return func.apply(this, arguments);
		} finally {
			lock.exit();
		}
	}
}