Crawler, first version

lib/task.js

+let {Logger} = require( "logger" );
+/**
+ * The default value for runaway_limit, used only in the constructor.
+ * @type {Number}
+ */
+const default_runaway_limit = 1000;
+
+/**
+ * Class for long-running tasks. Such tasks divide work into discrete units of effort, which allows them to be
+ * interrupted and to post progress.
+ * <p/>
+ * Note that are no callback or events in this class. Any state feedback should be implemented as needed within the
+ * task generator. task generator can distinguish cancellation by examining the rvalue of its yield statements. The
+ * generator cannot detect being paused, but the control object that started the task can.
+ * <p/>
+ * PLANNED: The current version will handle AJAX calls by polling the task generator every millisecond to see if there
+ * have been pending calls that have completed since the last poll. It would make for better performance for the task
+ * to signal that it should pause execution and then continue only after a pending call completes. This would eliminate
+ * run-time polling overhead.
+ * <p/>
+ * There would also need to be an interface presented to the task for pause and resume. Resuming is the harder one,
+ * because the task needs an object to call when 'Long_Task.prototype.run' is not in the call stack. Currently, the
+ * generator is instantiated before the constructor for this class, which means either passing such an object with
+ * 'send()' if that constructor is to be called. The better way is likely for this class to instantiate the generator
+ * with a pause/resume object as argument, but this only allows parametric generators (pretty much a requirement) if
+ * if 'Function.protoype.bind()' works on generator-functions (untried) or if an equivalent can be hacked up.
+ *
+ * @param {Generator} task_generator
+ *      The task generator is the task to be run, implemented as a generator. Each call to the generator performs an
+ *      increment of computation, whose size is determined by the task. This is part of a cooperative multitasking
+ *      system.
+ *      <p/>
+ *      Note that this argument is a generator, not the function that returns a generator when called. Instantiating
+ *      the generator with a function call is the responsibility of the code that instantiates this class.
+ *      <p/>
+ *      Note 'task_generator.next()' is always called at least once, because 'run()' calls that method before it detects
+ *      cancellation. This is required by the interface to a generator, since it's valid to call 'send()', which is how
+ *      the runner signals cancellation to the task, only after the first call to 'next'. If, for whatever reason, it's
+ *      necessary to detect cancellation before the work begins, the generator should have an extra do-nothing 'yield'
+ *      statement at the beginning.
+ *
+ * @param {Boolean} [may_pause=false]
+ *      The
+ *
+ * @param {Number} [runaway_limit]
+ *      The maximum number of iterations before 'run()' will throw an exception. Disable runaway detection by
+ *      setting this value to zero.
+ *
+ */
+var Long_Task = exports.Long_Task = function( task_instance, may_pause, runaway_limit )
+{
+    /**
+     * The core of a long task is a generator that runs on unit of computation with each call to next(). This object
+     * will give us such a generator by calling its generator() member.
+     * @type {*}
+     */
+    this.task_instance = task_instance;
+
+    /**
+     * The task generator for the task. It's initialized to null here, and set to the actual generator at the beginning
+     * of the run() method.
+     * <p/>
+     * It returns 'false' when it is not yet completed and 'true' once it has. Calling the generator with 'send( true )'
+     * notifies the generator that it has been cancelled; thereafter it must return 'true' always.
+     * @type {Boolean}
+     */
+    this.task_generator = null;
+
+    /**
+     * Cancellation flag. Set in the cancel() method. Tested each iteration in run().
+     * @type {Boolean}
+     */
+    this.cancelled = false;
+
+    /**
+     * Pause state flag.
+     * @type {Boolean}
+     */
+    this.paused = false;
+
+    /**
+     * Runnable flag. This is essentially the state variable of a two-state machine, which starts at "runnable" and
+     * goes to "completed".
+     * @type {Boolean}
+     */
+    this.runnable = true;
+
+    /**
+     * The maximum number of iterations before 'run()' will throw an exception. Disable runaway detection by setting
+     * this value to zero.
+     * @type {Number}
+     */
+    this.runaway_limit = (arguments.length < 2) ? default_runaway_limit : runaway_limit;
+
+    /**
+     * Iteration counter. This is only incremented when a runaway limit is in effect.
+     * @type {Number}
+     */
+    this.count = 0;
+
+    /**
+     * XPCOM thread manager. Used to implement dispatch().
+     * @type {nsIThreadManager}
+     */
+    this.thread_manager = Cc["@mozilla.org/thread-manager;1"].createInstance( Ci.nsIThreadManager );
+
+    /**
+     * Logging service.
+     * @type {Logger}
+     */
+    this.logger = new Logger( "Long_Task" );
+};
+
+/**
+ * Close the task out completely.
+ */
+Long_Task.prototype.close = function()
+{
+    this.cancel();
+
+    // DEFECT: We need to close the iterator, as well.
+    /*
+     * This is not trivial to implement correctly. If the task is paused, it means there's a pending operation that we
+     * cannot prevent from executing, but will at some point will call resume(). It's also possible that there's already
+     * another iteration of the main loop already dispatched.
+     */
+};
+
+/**
+ * Cancel command. Calling this function cancels the pending task as soon as possible, which is nowhere near
+ * immediate with JavaScript.
+ * <p/>
+ * WARNING: The current way that cancellation is implemented, there will be one additional call to the task
+ * generator before cancellation. If that's a problem, it's time to fix the algorithm, which means making
+ * an initial call to 'next()' before setting up the standing loop, and swapping the order of iterating and checking
+ * for cancellation.
+ */
+Long_Task.prototype.cancel = function()
+{
+    this.cancelled = true;
+};
+
+/**
+ * Run command
+ */
+Long_Task.prototype.run = function()
+{
+    var log = this.logger.make_log( "run" );
+    log( "Begin, runaway_limit = " + this.runaway_limit );
+
+    if ( !this.runnable )
+    {
+        throw "Long_Task no longer runnable";
+    }
+    this.task_generator = this.task_instance.generator( this.pause.bind( this ), this.resume.bind( this ) );
+    this._run_once();
+};
+
+/**
+ * The main body of the runner.
+ */
+Long_Task.prototype._run_once = function()
+{
+    var log = this.logger.make_log( "_run_once" );
+
+    /*
+     * The bulk of this function is structure as 'do ... while( false )' in order to use 'break' for flow control,
+     * instead of splitting off a second function and using 'return'.
+     */
+    //noinspection LoopStatementThatDoesntLoopJS
+    do
+    {
+        /*
+         * If we must pause, we simply don't do anything else now. The landing code of the asynchronous object must
+         * call resume(), which will dispatch the present function again and start the iteration cycle up again.
+         */
+        if ( this.paused )
+        {
+            return;
+            /*
+             * FUTURE: start a watchdog timer here that will cancel the object if the task times out.
+             */
+        }
+
+        /*
+         * Main iteration call. The call to run() goes into a try-block to ensure we stop gracefully if the generator
+         * throws, since that doesn't always signal an error
+         */
+        try
+        {
+            if ( this.task_generator.next() )
+            {
+                /*
+                 * The task generator returned true, which means that it's finished.
+                 */
+                break;
+            }
+        }
+        catch ( ex )
+        {
+            if ( ex === StopIteration )
+            {
+                log( "End. Task iterator stopped" );
+                /*
+                 * StopIteration is not an error but just signals the end of data for an ordinary iterator. Since the
+                 * generator has signalled us, we don't send any signal by calling 'send()'.
+                 */
+                break;
+            }
+            else
+            {
+                log( "Iteration exception " + ex.toString() );
+                throw ex;
+            }
+        }
+
+        /*
+         * Runaway detection.
+         */
+        if ( this.runaway_limit > 0 )
+        {
+            ++this.count;
+            log( "Iteration " + this.count, false );
+            if ( this.count >= this.runaway_limit )
+            {
+                this.cancelled = true;
+                /*
+                 * FUTURE: This should really throw an exception after cancelling the generator.
+                 */
+            }
+        }
+
+        /*
+         * Cancellation detection.
+         */
+        if ( this.cancelled )
+        {
+            log( "Cancellation begin" );
+            try
+            {
+                /*
+                 * We've received a command to cancel from elsewhere. Notify the generator that we're shutting down and
+                 * exit the loop. We're doing this within a try-block because the generator will typically throw
+                 * StopIteration at this point, which isn't an error.
+                 */
+                this.task_generator.send( true );
+            }
+            catch ( ex )
+            {
+                /*
+                 * StopIteration is not an error as a result of cancellation, but any other exception is.
+                 */
+                if ( ex !== StopIteration )
+                {
+                    log( "Cancellation exception: " + ex.toString() );
+                    throw ex;
+                }
+            }
+            log( "Cancellation end" );
+            break;
+        }
+
+        /*
+         * Infinite loop behavior happens here, where we schedule ourselves for another run as soon as possible
+         * after we complete. This uses the container's thread manager, so it executes more-or-less immediately.
+         * If there are long-duration asynchronous actions in the task, such as loading web pages or AJAX calls,
+         * this routine runs too fast to be effective as a poll. Such tasks should pause when such operations are
+         * pending.
+         */
+        this.dispatch();
+        return;
+    } while ( false );
+    this.runnable = false;
+};
+
+/**
+ * Pause instruction. Since JavaScript is not multi-threaded, the pause instruction does not block. Instead, it takes
+ * effect at the next 'yield' statement.
+ */
+Long_Task.prototype.pause = function()
+{
+    this.paused = true;
+};
+
+/**
+ *
+ */
+Long_Task.prototype.resume = function()
+{
+    this.paused = false;
+    this.dispatch();
+};
+
+/**
+ * Dispatch another iteration. This is used ordinarily at the end of _run_once() and also by resume() to restart
+ * the iteration.
+ */
+Long_Task.prototype.dispatch = function()
+{
+    this.thread_manager.currentThread.dispatch(
+        {run: this._run_once.bind( this )},
+        Ci.nsIEventTarget.DISPATCH_NORMAL
+    );
+};
+