process,worker: ensure code followed by exit() effectless

Cope with the delay(to the next function call) of
v8::Isolate::TerminateExecution()

Author: ywave620

lib/internal/process/per_thread.js

@@ -104,6 +104,8 @@ function hrtimeBigInt() {
   return hrBigintValues[0];
 }
 
+function nop() {}
+
 // The execution of this function itself should not cause any side effects.
 function wrapProcessMethods(binding) {
   const {
@@ -195,6 +197,16 @@ function wrapProcessMethods(binding) {
     // in the user land. Either document it, or deprecate it in favor of a
     // better public alternative.
     process.reallyExit(process.exitCode || kNoFailure);
+
+    // If this is a worker, v8::Isolate::TerminateExecution() is called above.
+    // That function spoofs the stack pointer to cause the stack guard
+    // check to throw the termination exception. Because v8 performs
+    // stack guard check upon every function call, we give it a chance.
+    //
+    // Without this, user code followed by `process.exit()` would take effect.
+    // test/parallel/test-worker-voluntarily-exit-followed-by-addition.js
+    // test/parallel/test-worker-voluntarily-exit-followed-by-throw.js
+    nop();
   }
 
   function kill(pid, sig) {

test/cctest/test_environment.cc

@@ -553,7 +553,9 @@ TEST_F(EnvironmentTest, ExitHandlerTest) {
     callback_calls++;
     node::Stop(*env);
   });
-  node::LoadEnvironment(*env, "process.exit(42)").ToLocalChecked();
+  // When terminating, v8 throws makes the current embedder call bail out
+  // with MaybeLocal<>()
+  EXPECT_TRUE(node::LoadEnvironment(*env, "process.exit(42)").IsEmpty());
   EXPECT_EQ(callback_calls, 1);
 }
 

test/node-api/test_worker_terminate/test.js

@@ -19,8 +19,8 @@ if (isMainThread) {
   const { Test } = require(`./build/${common.buildType}/test_worker_terminate`);
 
   const { counter } = workerData;
-  // Test() tries to call a function twice and asserts that the second call does
-  // not work because of a pending exception.
+  // Test() tries to call a function and asserts it fails because of a
+  // pending termination exception.
   Test(() => {
     Atomics.add(counter, 0, 1);
     process.exit();

test/node-api/test_worker_terminate/test_worker_terminate.c

@@ -17,8 +17,6 @@ napi_value Test(napi_env env, napi_callback_info info) {
   NODE_API_ASSERT(env, t == napi_function,
       "Wrong first argument, function expected.");
 
-  status = napi_call_function(env, recv, argv[0], 0, NULL, NULL);
-  assert(status == napi_ok);
   status = napi_call_function(env, recv, argv[0], 0, NULL, NULL);
   assert(status == napi_pending_exception);
 

test/parallel/test-async-hooks-worker-asyncfn-terminate-4.js

@@ -12,6 +12,7 @@ const { Worker } = require('worker_threads');
 const workerData = new Int32Array(new SharedArrayBuffer(4));
 const w = new Worker(`
 const { createHook } = require('async_hooks');
+const { workerData } = require('worker_threads');
 
 setImmediate(async () => {
   createHook({ init() {} }).enable();

test/parallel/test-worker-voluntarily-exit-followed-by-addition.js

@@ -0,0 +1,18 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const { Worker, isMainThread } = require('worker_threads');
+
+if (isMainThread) {
+  const workerData = new Int32Array(new SharedArrayBuffer(4));
+  const w = new Worker(__filename, {
+    workerData,
+  });
+  w.on('exit', common.mustCall(() => {
+    assert.strictEqual(workerData[0], 0);
+  }));
+} else {
+  const { workerData } = require('worker_threads');
+  process.exit();
+  workerData[0] = 1;
+}

test/parallel/test-worker-voluntarily-exit-followed-by-throw.js

@@ -0,0 +1,23 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const { Worker, isMainThread } = require('worker_threads');
+
+if (isMainThread) {
+  const workerData = new Int32Array(new SharedArrayBuffer(4));
+  const w = new Worker(__filename, {
+    workerData,
+  });
+  w.on('exit', common.mustCall(() => {
+    assert.strictEqual(workerData[0], 0);
+  }));
+} else {
+  const { workerData } = require('worker_threads');
+  try {
+    process.exit();
+    throw new Error('xxx');
+    // eslint-disable-next-line no-unused-vars
+  } catch (err) {
+    workerData[0] = 1;
+  }
+}