update

src/paraEncode.js

@@ -69,8 +69,11 @@ export class ParaEncoder {
     return this.#grp.isDone();
   }
 
-
   async getResult() {
     return this.#grp.getResult();
   }
+
+  close() {
+    this.#grp.terminate();
+  }
 }

tests/ENCH264Group.spec.js

 import { sleep, waitCond } from '../src/utils.js';
 import { H264EncWWGroup, H264GRP_OPTIONS } from '../src/encGroup.js';
 
-describe("H264EncWWGroup Spec", () => {
+xdescribe("H264EncWWGroup Spec", () => {
   it("Instantiation", async () => {
     let wg = new H264EncWWGroup("h264enc", 2);
     await wg.start();

tests/paraEncodeSpec.spec.js

@@ -6,8 +6,7 @@ const RGBAFrameSize = 1920*1080*4;
 
 describe("ParaEncoder", () => {
   beforeEach(async () => {
-    let trNum = navigator.hardwareConcurrency;
-    paraEnc = new ParaEncoder(trNum, {
+    paraEnc = new ParaEncoder(3, {
       codec: "H264",
       config: {
         encchnlsize: RGBAFrameSize * 10,
@@ -17,11 +16,15 @@ describe("ParaEncoder", () => {
     await paraEnc.init();
   }, 20000);
 
-  xit("Encode With ParaEncoder", async () => {
+  afterEach(() => {
+    paraEnc.close();
+  });
+
+  it("Encode With ParaEncoder", async () => {
     const data = new Uint8Array([...Array(RGBAFrameSize).keys()]);
 
     let st = new Date();
-    for (let i = 0; i < 300; ++i) {
+    for (let i = 0; i < 30; ++i) {
       await paraEnc.encode(data);
     }
 
@@ -35,10 +38,11 @@ describe("ParaEncoder", () => {
   }, 3000000);
 });
 
+let paraEnc_;
+
 describe("ParaEncoder Blockbased", () => {
   beforeEach(async () => {
-    let trNum = navigator.hardwareConcurrency;
-    paraEnc = new ParaEncoder(trNum, {
+    paraEnc_ = new ParaEncoder(3, {
       codec: "H264",
       config: {
         encchnlsize: RGBAFrameSize * 10,
@@ -49,18 +53,20 @@ describe("ParaEncoder Blockbased", () => {
         fps: 25
       }
     });
-    await paraEnc.init();
+    await paraEnc_.init();
   }, 20000);
 
+  afterEach(() => { paraEnc_.close() })
+
   it("Encode With DirectWrite", async () => {
     const data = new Uint8Array([...Array(RGBAFrameSize).keys()]);
 
 
     let st = new Date();
-    for (let i = 0; i < 300; ++i) {
+    for (let i = 0; i < 30; ++i) {
       let buffers = [];
       while (true) {
-        buffers = paraEnc.directWPrepare(RGBAFrameSize);
+        buffers = paraEnc_.directWPrepare(RGBAFrameSize);
         if (buffers.length > 0)
           break;
         else
@@ -69,11 +75,11 @@ describe("ParaEncoder Blockbased", () => {
 
       expect(buffers.length).toBe(1);
       buffers[0].set(data, 0);
-      await paraEnc.directWConfirm();
+      await paraEnc_.directWConfirm();
     }
 
-    await paraEnc.encode(null);
-    await waitCond(() => paraEnc.isDone(), 3000000, 300);
+    await paraEnc_.encode(null);
+    await waitCond(() => paraEnc_.isDone(), 3000000, 300);
     let et = new Date();
 
     let diff = (et - st) / 1000;