use __WASI_ERRNO_BUSY in tsfn JS lock

Author: toyobayashi

packages/emnapi/src/threadsafe-function.ts

@@ -258,18 +258,18 @@ const emnapiTSFN = {
         const i32a = new Int32Array(wasmMemory.buffer, index, 1)
         if (isBrowserMain) {
           while (true) {
-            const oldValue = Atomics.compareExchange(i32a, 0, 0, 1)
+            const oldValue = Atomics.compareExchange(i32a, 0, 0, 10)
             if (oldValue === 0) {
               return
             }
           }
         } else {
           while (true) {
-            const oldValue = Atomics.compareExchange(i32a, 0, 0, 1)
+            const oldValue = Atomics.compareExchange(i32a, 0, 0, 10)
             if (oldValue === 0) {
               return
             }
-            Atomics.wait(i32a, 0, 1)
+            Atomics.wait(i32a, 0, 10)
           }
         }
       },
@@ -278,20 +278,20 @@ const emnapiTSFN = {
           const again = (): void => { fn() }
           const fn = (): void => {
             const i32a = new Int32Array(wasmMemory.buffer, index, 1)
-            const oldValue = Atomics.compareExchange(i32a, 0, 0, 1)
+            const oldValue = Atomics.compareExchange(i32a, 0, 0, 10)
             if (oldValue === 0) {
               resolve()
               return
             }
-            (Atomics as any).waitAsync(i32a, 0, 1).value.then(again)
+            (Atomics as any).waitAsync(i32a, 0, 10).value.then(again)
           }
           fn()
         })
       }, */
       unlock () {
         const i32a = new Int32Array(wasmMemory.buffer, index, 1)
-        const oldValue = Atomics.compareExchange(i32a, 0, 1, 0)
-        if (oldValue !== 1) {
+        const oldValue = Atomics.compareExchange(i32a, 0, 10, 0)
+        if (oldValue !== 10) {
           throw new Error('Tried to unlock while not holding the mutex')
         }
         Atomics.notify(i32a, 0, 1)

packages/test/script/test.js

@@ -21,6 +21,7 @@ const pthread = [
   'node-addon-api/**/*',
   'pool/**/*',
   'tsfn/**/*',
+  'tsfn_shutdown/**/*',
   'async_cleanup_hook/**/*',
   'string/string-pthread.test.js',
   'uv_threadpool_size/**/*',