diff --git a/test/threadsafe_function/threadsafe_function.js b/test/threadsafe_function/threadsafe_function.js index 7da0e3df6..5236f28ea 100644 --- a/test/threadsafe_function/threadsafe_function.js +++ b/test/threadsafe_function/threadsafe_function.js @@ -25,11 +25,9 @@ async function test(binding) { binding.threadsafe_function[threadStarter](function testCallback(value) { array.push(value); if (array.length === quitAfter) { - setImmediate(() => { - binding.threadsafe_function.stopThread(common.mustCall(() => { - resolve(array); - }), !!abort); - }); + binding.threadsafe_function.stopThread(common.mustCall(() => { + resolve(array); + }), !!abort); } }, !!abort, !!launchSecondary, maxQueueSize); if (threadStarter === 'startThreadNonblocking') { diff --git a/test/typed_threadsafe_function/typed_threadsafe_function.js b/test/typed_threadsafe_function/typed_threadsafe_function.js index 5d4a52a79..51bbf2f73 100644 --- a/test/typed_threadsafe_function/typed_threadsafe_function.js +++ b/test/typed_threadsafe_function/typed_threadsafe_function.js @@ -25,11 +25,9 @@ async function test(binding) { binding.typed_threadsafe_function[threadStarter](function testCallback(value) { array.push(value); if (array.length === quitAfter) { - setImmediate(() => { - binding.typed_threadsafe_function.stopThread(common.mustCall(() => { - resolve(array); - }), !!abort); - }); + binding.typed_threadsafe_function.stopThread(common.mustCall(() => { + resolve(array); + }), !!abort); } }, !!abort, !!launchSecondary, maxQueueSize); if (threadStarter === 'startThreadNonblocking') {