From ac44bdd9b30a3621aaf17717965bf61733aed932 Mon Sep 17 00:00:00 2001
From: "Alex A. Naanou" <alex.nanou@gmail.com>
Date: Mon, 20 Jan 2014 20:49:02 +0400
Subject: [PATCH] added a generic deferred pool...

Signed-off-by: Alex A. Naanou <alex.nanou@gmail.com>
---
 ui/files.js   |  3 +-
 ui/lib/jli.js | 97 +++++++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 99 insertions(+), 1 deletion(-)

diff --git a/ui/files.js b/ui/files.js
index 1fb7512c..0686ede6 100755
--- a/ui/files.js
+++ b/ui/files.js
@@ -890,7 +890,7 @@ function exportImagesTo(path, im_name, dir_name, size){
 		}
 		var worker = exportImageTo.apply(null, e)
 			.done(function(){
-				// remove self from pool...
+				// prepare remove self from pool...
 				var i = pool.indexOf(worker)
 
 				// get the next queue item...
@@ -898,6 +898,7 @@ function exportImagesTo(path, im_name, dir_name, size){
 
 				// enqueue the next worker if it exists...
 				if(next != null){
+					// replace self with next worker...
 					pool[i] = enqueue(next)
 
 				// nothing in queue...
diff --git a/ui/lib/jli.js b/ui/lib/jli.js
index 62301329..15dd27fd 100755
--- a/ui/lib/jli.js
+++ b/ui/lib/jli.js
@@ -725,6 +725,103 @@ function makeDeferredsQ(first){
 }
 
 
+// XXX should this be an object or a factory???
+function makeDefferedPool(size){
+	var pool = {
+		pool: [],
+		size: size,
+		queue: [],
+	}
+
+	pool._done_handlers = []
+
+	pool._run = function(obj, func, args){
+		var that = this
+		var pool = this.pool
+		var pool_size = this.size
+		var queue = this.queue
+		var run = this._run
+
+		// run an element from the queue...
+		var worker = func.apply(obj, args)
+			.always(function(){
+				// prepare to remove self from pool...
+				var i = pool.indexOf(worker)
+
+				// shrink the pool if it's overfilled...
+				if(pool.length > pool_size){
+					// remove self...
+					pool.splice(i, 1)
+					return
+				}
+
+				// get the next queue item...
+				var next = queue.splice(0, 1)[0]
+
+				// run the next worker if it exists...
+				if(next != null){
+					// replace self with next worker...
+					pool[i] = run.apply(that, next)
+
+				// nothing in queue...
+				} else {
+					// remove self...
+					pool.splice(i, 1)
+
+					// empty queue and empty pool mean we are done...
+					if(pool.length == 0){
+						that._done()
+					}
+				}
+
+				// keep the pool full...
+				that._fill()
+			})
+			.fial(function(){
+				// XXX
+			})
+
+		return worker
+	}
+	pool._fill = function(){
+		var that = this
+		var pool = this.pool
+		var pool_size = this.size
+		var run = this._run
+		var res = []
+
+		if(pool.length < pool_size && this.queue.length > 0){
+			res = this.queue.splice(0, pool_size - pool.length)
+				.forEach(function(e){
+					pool.push = run.apply(that, e)
+				})
+		}
+
+		return res
+	}
+	pool._done(){
+		var that = this
+		this._done_handlers.forEach(function(func){
+			func(that)
+		})
+	}
+
+	// public methods...
+	pool.enqueue = function(obj, func, args){
+		// add worker to queue...
+		this.queue.push([obj, func, args])
+
+		// start work if we have not already...
+		this._fill()
+	}
+	pool.done = function(func){
+		this._done_handlers.push(func)
+	}
+
+	return pool
+}
+
+
 
 /**************************************************** JS utilities ***/