Napi::Value Tsfn(const Napi::CallbackInfo &info) {
  Napi::Env env = info.Env();
  std::atomic<uint32_t> *extraQueuedCounts = new std::atomic<uint32_t>{0};
  napi_threadsafe_function tsfn = nullptr;
  napi_create_threadsafe_function(
      env, nullptr, nullptr, Napi::String::New(env, "hello"), MAX_QUEUE_SIZE, 1,
      nullptr, nullptr, nullptr,
      [](napi_env, napi_value, void *, void *data) {
        std::cout << "executed: " << (uintptr_t)data << std::endl;
      },
      &tsfn);
  // It fulled queue of tsfn
  for (uint32_t i = 0; i < MAX_QUEUE_SIZE; i++) {
    napi_call_threadsafe_function(tsfn, (void *)uintptr_t(i),
                                  napi_tsfn_blocking);
  }
  for (uint32_t i = 0; i < MAX_QUEUE_SIZE; i++) {
    std::thread(
        [&i](napi_threadsafe_function tsfn, std::atomic<uint32_t> *counter) {
          std::cout << "waiting: " << gettid() << std::endl;
          napi_call_threadsafe_function(tsfn, (void *)uintptr_t(i + 3),
                                        napi_tsfn_blocking);
          (*counter)++;
          std::cout << "called: " << gettid() << std::endl;
          // release tsfn after all task queued
          if (counter->load() == MAX_QUEUE_SIZE) {
            napi_release_threadsafe_function(tsfn, napi_tsfn_release);
          }
        },
        tsfn, extraQueuedCounts)
        .detach();
  }
  std::cout << "queued count: " << extraQueuedCounts->load() << std::endl;
  return env.Undefined();
}