From b8d14c0e60abd159db89c1af72cad634cbed3bed Mon Sep 17 00:00:00 2001
From: John French <johnfrench093@gmail.com>
Date: Wed, 20 Apr 2022 18:05:55 +0200
Subject: [PATCH] src: check for tsfn in conditional_variable wait

Fixes: #1150

PR-URL: https://github.com/nodejs/node-addon-api/pull/1168
Reviewed-By: Michael Dawson <midawson@redhat.com
---
 test/threadsafe_function/threadsafe_function_sum.cc             | 2 +-
 test/typed_threadsafe_function/typed_threadsafe_function_sum.cc | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/test/threadsafe_function/threadsafe_function_sum.cc b/test/threadsafe_function/threadsafe_function_sum.cc
index 5134e58..019b0ce 100644
--- a/test/threadsafe_function/threadsafe_function_sum.cc
+++ b/test/threadsafe_function/threadsafe_function_sum.cc
@@ -81,7 +81,7 @@ class DelayedTSFNTask {
   // Entry point for std::thread
   void entryDelayedTSFN(int threadId) {
     std::unique_lock<std::mutex> lk(mtx);
-    cv.wait(lk);
+    cv.wait(lk, [this] { return this->tsfn != nullptr; });
     tsfn.BlockingCall([=](Napi::Env env, Function callback) {
       callback.Call({Number::New(env, static_cast<double>(threadId))});
     });
diff --git a/test/typed_threadsafe_function/typed_threadsafe_function_sum.cc b/test/typed_threadsafe_function/typed_threadsafe_function_sum.cc
index 9add259..b36ab28 100644
--- a/test/typed_threadsafe_function/typed_threadsafe_function_sum.cc
+++ b/test/typed_threadsafe_function/typed_threadsafe_function_sum.cc
@@ -99,7 +99,7 @@ class DelayedTSFNTask {
   // Entry point for std::thread
   void entryDelayedTSFN(int threadId) {
     std::unique_lock<std::mutex> lk(mtx);
-    cv.wait(lk);
+    cv.wait(lk, [this] { return this->tsfn != nullptr; });
     tsfn.BlockingCall(new double(threadId));
     tsfn.Release();
   };