test runtime UV_THREADPOOL_SIZE

toyobayashi · Aug 25, 2023 · e92ad8f · e92ad8f
1 parent 523e4f9
commit e92ad8f
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 8 deletions.
diff --git a/packages/test/CMakeLists.txt b/packages/test/CMakeLists.txt
@@ -50,12 +50,12 @@ else()
 endif()
 
 if(DEFINED ENV{UV_THREADPOOL_SIZE})
-  set(EMNAPI_WORKER_POOL_SIZE $ENV{UV_THREADPOOL_SIZE})
+  set(UV_THREADPOOL_SIZE $ENV{UV_THREADPOOL_SIZE})
 else()
-  set(EMNAPI_WORKER_POOL_SIZE "4")
+  set(UV_THREADPOOL_SIZE "4")
 endif()
 
-math(EXPR PTHREAD_POOL_SIZE "${EMNAPI_WORKER_POOL_SIZE} * 4")
+math(EXPR PTHREAD_POOL_SIZE "${UV_THREADPOOL_SIZE} * 4")
 
 if(IS_WASM)
   include_directories("${CMAKE_CURRENT_SOURCE_DIR}/../emnapi/include")
@@ -257,11 +257,7 @@ add_test("tsfn2" "./tsfn2/binding.c" OFF ON "")
 
 if((NOT IS_WASM) OR IS_EMSCRIPTEN OR IS_WASI_THREADS)
   add_test("string_mt" "./string/binding.c;./string/test_null.c" ON ON "")
-  if(IS_EMSCRIPTEN)
-  add_test("pool" "./pool/binding.c" OFF ON "--pre-js=${CMAKE_CURRENT_SOURCE_DIR}/pool/pre.js")
-  else()
   add_test("pool" "./pool/binding.c" OFF ON "")
-  endif()
   add_test("tsfn" "./tsfn/binding.c" OFF ON "")
   add_test("async_cleanup_hook" "./async_cleanup_hook/binding.c" OFF ON "")
   add_test("uv_threadpool_size" "./uv_threadpool_size/binding.c" OFF ON "")

diff --git a/packages/test/util.js b/packages/test/util.js
@@ -25,6 +25,8 @@ function getEntry (targetName) {
 
 exports.getEntry = getEntry
 
+const RUNTIME_UV_THREADPOOL_SIZE = ('UV_THREADPOOL_SIZE' in process.env) ? Number(process.env.UV_THREADPOOL_SIZE) : 4
+
 function loadPath (request, options) {
   try {
     if (process.env.EMNAPI_TEST_NATIVE) {
@@ -74,7 +76,7 @@ function loadPath (request, options) {
       const { createNapiModule, loadNapiModule } = require('@emnapi/core')
       const napiModule = createNapiModule({
         context,
-        asyncWorkPoolSize: ('UV_THREADPOOL_SIZE' in process.env) ? Number(process.env.UV_THREADPOOL_SIZE) : 4,
+        asyncWorkPoolSize: RUNTIME_UV_THREADPOOL_SIZE,
         onCreateWorker () {
           return new Worker(join(__dirname, './worker.js'), {
             env: process.env
@@ -127,6 +129,7 @@ function loadPath (request, options) {
       try {
         resolve(Module.emnapiInit({
           context,
+          asyncWorkPoolSize: RUNTIME_UV_THREADPOOL_SIZE,
           ...(options || {})
         }))
       } catch (err) {