flynx/ImageGrid
1
1
Fork 0
mirror of https://github.com/flynx/ImageGrid.git synced 2025-10-29 18:30:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

revised deferred pool docs...

Browse Source 
Signed-off-by: Alex A. Naanou <alex.nanou@gmail.com>
This commit is contained in:
Alex A. Naanou 2014-01-21 19:28:53 +04:00
parent e8001d7fff
commit 7e045c9c7f
1 changed files with 33 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
ui/lib/jli.js
View File

@ -730,35 +730,39 @@ function makeDeferredsQ(first){
// Deferred worker pool... // Deferred worker pool...
// //
// makeDefferedPool([size][, paused]) -> pool
//
//
// This will create and return a pooled queue of deferred workers. // This will create and return a pooled queue of deferred workers.
// //
// Public interface: // Public interface:
// //
// .enqueue(obj, func, args) // .enqueue(obj, func, args) -> pool
// Add a worker to queue. // Add a worker to queue.
// If the pool is empty this will run the worker right away. // If the pool is not filled and not paused, this will run the
// If the pool is full the worker is added to queue (FILO) and // worker right away.
// run as it's turn arrives. // If the pool is full the worker is added to queue (FIFO) and
// ran in its turn.
// //
// .dropQueue() // .pause() -> pool
// Pause the queue.
// NOTE: this also has a second form: .pause(func), see below.
//
// .resume() -> pool
// Restart the queue.
//
// .dropQueue() -> pool
// Drop the queued workers. // Drop the queued workers.
// NOTE: this will not stop the already running workers. // NOTE: this will not stop the already running workers.
// //
// .pause() // .isRunning() -> bool
// Pause the queue.
//
// .pause(func)
// Register a pause handler.
// This handler is called after the last worker finishes when
// the queue is paused.
//
// .resume()
// Restart the queue.
//
// .isRunning()
// Test if any workers are running in the pool. // Test if any workers are running in the pool.
// NOTE: this will return false ONLY when the pool is empty.
// //
// .progress(func) //
// Handler/callback registration:
//
// .progress(func) -> pool
// Register a progress handler. // Register a progress handler.
// The handler is called after each worker is done and will get // The handler is called after each worker is done and will get
// passed: // passed:
@ -768,7 +772,7 @@ function makeDeferredsQ(first){
// NOTE: the total number of workers can change as new workers // NOTE: the total number of workers can change as new workers
// are added or the queue is cleared... // are added or the queue is cleared...
// //
// .fail(func) // .fail(func) -> pool
// Register a worker fail handler. // Register a worker fail handler.
// The handler is called when a worker goes into the fail state. // The handler is called when a worker goes into the fail state.
// This will get passed: // This will get passed:
@ -777,7 +781,12 @@ function makeDeferredsQ(first){
// - workers total count // - workers total count
// NOTE: this will not stop the execution of other handlers. // NOTE: this will not stop the execution of other handlers.
// //
// .depleted(func) // .pause(func) -> pool
// Register a pause handler.
// This handler is called after the last worker finishes when
// the queue is paused.
//
// .depleted(func) -> pool
// Register a depleted pool handler. // Register a depleted pool handler.
// The handler will get called when the queue and pool are empty // The handler will get called when the queue and pool are empty
// (depleted) and the last worker is done. // (depleted) and the last worker is done.
@ -907,8 +916,10 @@ function makeDefferedPool(size, paused){
// Drop the queued workers... // Drop the queued workers...
// //
// NOTE: this will not stop the running workers... // NOTE: this will not stop the running workers...
// XXX should this return the pool or the dropped queue???
Pool.dropQueue = function(){ Pool.dropQueue = function(){
this.queue.splice(0, this.queue.length) this.queue.splice(0, this.queue.length)
return this
} }
Pool.isRunning = function(){ Pool.isRunning = function(){
@ -930,7 +941,9 @@ function makeDefferedPool(size, paused){
} }
return this return this
} }
// XXX do we need a resume callback??? // XXX do we need a resume callback???
// XXX test...
Pool.resume = function(){ Pool.resume = function(){
this._paused = false this._paused = false
this._fill() this._fill()