refactor: dispatch async work queue in shared memory (#201)

Author: toyobayashi

packages/bench/package.json

@@ -6,7 +6,7 @@
     "rebuild": "emcmake cmake -DCMAKE_BUILD_TYPE=Release -H. -B.build && cmake --build .build"
   },
   "devDependencies": {
-    "node-addon-api": "^7.0.0",
+    "node-addon-api": "^8.6.0",
     "benchmark": "^2.1.4"
   }
 }

packages/core/src/emnapi/index.d.ts

@@ -39,8 +39,7 @@ export declare interface NapiModule {
   }
 
   init (options: InitOptions): any
-  initWorker (arg: number): void
-  executeAsyncWork (work: number): void
+  initWorker (arg: number, func: [number, number]): void
   postMessage?: (msg: any) => any
 
   waitThreadStart: boolean | number

packages/core/src/worker.ts

@@ -64,11 +64,7 @@ export class MessageHandler extends ThreadMessageHandler {
       try {
         if (type === 'async-worker-init') {
           this.handleAfterLoad(e, () => {
-            this.napiModule!.initWorker(payload.arg)
-          })
-        } else if (type === 'async-work-execute') {
-          this.handleAfterLoad(e, () => {
-            this.napiModule!.executeAsyncWork(payload.work)
+            this.napiModule!.initWorker(payload.arg, payload.func)
           })
         }
       } catch (err) {

packages/emnapi/script/build.js

@@ -290,7 +290,9 @@ async function buildNonEmscriptenPlugin (tsconfigPath, input, output, destructPl
   ${parsedCode}
   return {
     importObject: (original) => {
-${exportModules.map(modName => {
+${typeof exportModules === 'function'
+  ? exportModules(modVar)
+  : exportModules.map(modName => {
   return `      Object.assign(original.${modName}, ${modVar})`
 })}
     }
@@ -354,7 +356,16 @@ async function build () {
       path.join(__dirname, '../src/core/async-work.ts'),
       path.join(outputDir, 'async-work.js'),
       ['emnapiCtx', 'emnapiNodeBinding', 'emnapiAsyncWorkPoolSize'],
-      ['napi']
+      function (modVar) {
+        return `
+      Object.keys(${modVar}).forEach(key => {
+        if (key.startsWith('napi_') || key.startsWith('node_api_')) {
+          original.napi[key] = ${modVar}[key]
+        } else {
+          original.env[key] = ${modVar}[key]
+        }
+      })`
+      }
     ),
     buildNonEmscriptenPlugin(
       coreTsconfigPath,