nodejs
diff --git a/Collapse file
‎lib/internal/main/worker_thread.js‎
Copy file name to clipboardExpand all lines: lib/internal/main/worker_thread.js
+21-19Lines changed: 21 additions & 19 deletions b/Collapse file
‎lib/internal/main/worker_thread.js‎
Copy file name to clipboardExpand all lines: lib/internal/main/worker_thread.js
+21-19Lines changed: 21 additions & 19 deletions
diff --git a/Collapse file
‎test/parallel/test-worker-non-fatal-uncaught-exception.js‎
Copy file name to clipboard
+25Lines changed: 25 additions & 0 deletions b/Collapse file
‎test/parallel/test-worker-non-fatal-uncaught-exception.js‎
Copy file name to clipboard
+25Lines changed: 25 additions & 0 deletions
@@ -161,26 +161,28 @@ function workerOnGlobalUncaughtException(error, fromPromise) {
   }
   debug(`[${threadId}] uncaught exception handled = ${handled}`);
 
-  if (!handled) {
-    let serialized;
-    try {
-      const { serializeError } = require('internal/error-serdes');
-      serialized = serializeError(error);
-    } catch {}
-    debug(`[${threadId}] uncaught exception serialized = ${!!serialized}`);
-    if (serialized)
-      port.postMessage({
-        type: ERROR_MESSAGE,
-        error: serialized
-      });
-    else
-      port.postMessage({ type: COULD_NOT_SERIALIZE_ERROR });
-
-    const { clearAsyncIdStack } = require('internal/async_hooks');
-    clearAsyncIdStack();
-
-    process.exit();
+  if (handled) {
+    return true;
   }
+
+  let serialized;
+  try {
+    const { serializeError } = require('internal/error-serdes');
+    serialized = serializeError(error);
+  } catch {}
+  debug(`[${threadId}] uncaught exception serialized = ${!!serialized}`);
+  if (serialized)
+    port.postMessage({
+      type: ERROR_MESSAGE,
+      error: serialized
+    });
+  else
+    port.postMessage({ type: COULD_NOT_SERIALIZE_ERROR });
+
+  const { clearAsyncIdStack } = require('internal/async_hooks');
+  clearAsyncIdStack();
+
+  process.exit();
 }
 
 // Patch the global uncaught exception handler so it gets picked up by
 
@@ -0,0 +1,25 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const { Worker } = require('worker_threads');
+
+// Check that `process._fatalException()` returns a boolean when run inside a
+// worker.
+
+// Do not use isMainThread so that this test itself can be run inside a Worker.
+if (!process.env.HAS_STARTED_WORKER) {
+  process.env.HAS_STARTED_WORKER = 1;
+  const w = new Worker(__filename);
+  w.on('exit', common.mustCall((code) => {
+    assert.strictEqual(code, 0);
+  }));
+  return;
+}
+
+process.once('uncaughtException', () => {
+  process.nextTick(() => {
+    assert.strictEqual(res, true);
+  });
+});
+
+const res = process._fatalException(new Error());