init

nv/html/dwv/tests/utils/thread.test.js

@@ -0,0 +1,56 @@
+/**
+ * Tests for the 'utils/thread' file.
+ */
+/** @module tests/utils */
+// Do not warn if these variables were not defined before.
+/* global QUnit */
+QUnit.module("thread");
+
+/**
+ * Tests for {@link dwv.utils.ThreadPool}.
+ * @function module:tests/utils~ThreadPool
+ */
+QUnit.test("Test ThreadPool.", function (assert) {
+
+    var done = assert.async();
+
+    // create the thread pool and initialise it
+    var pool = new dwv.utils.ThreadPool(20);
+    pool.init();
+
+    // number of workers
+    var nTestWorkers = 10;
+
+    // called on pool end, should be last
+    pool.onpoolworkend = function () {
+        // check counters
+        assert.equal(countWorkerCallback, nTestWorkers, "Count WorkerCallback");
+        assert.equal(countWorkerEnd, nTestWorkers, "Count WorkerEnd");
+        // finish async test
+        done();
+    };
+
+    // called on worker end
+    var countWorkerEnd = 0;
+    pool.onworkerend = function () {
+        ++countWorkerEnd;
+    };
+
+    // worker callback: check returned data
+    var countWorkerCallback = 0;
+    var workerCallback = function (event) {
+        if (event.data[0] === "papageno papagena") {
+            ++countWorkerCallback;
+        }
+    };
+
+    // create the workers and run them
+    for ( var i = 0; i < nTestWorkers; ++i ) {
+        // create worker task
+        var workerTask = new dwv.utils.WorkerTask(
+            "./utils/worker.js", workerCallback, {"input": "papageno"} );
+        // add it the queue and run it
+        pool.addWorkerTask(workerTask);
+    }
+
+});