only execute if inside worker thread

Author: Kartik Raj

src/client/common/process/worker/plainExecWorker.ts

@@ -1,16 +1,18 @@
-import { parentPort, workerData } from 'worker_threads';
+import { isMainThread, parentPort, workerData } from 'worker_threads';
 import { workerPlainExec } from './workerRawProcessApis';
 
-workerPlainExec(workerData.file, workerData.args, workerData.options, workerData.defaultEnv, workerData.disposables)
-    .then((res) => {
-        if (!parentPort) {
-            throw new Error('Not in a worker thread');
-        }
-        parentPort.postMessage({ res });
-    })
-    .catch((err) => {
-        if (!parentPort) {
-            throw new Error('Not in a worker thread');
-        }
-        parentPort.postMessage({ err });
-    });
+if (!isMainThread) {
+    workerPlainExec(workerData.file, workerData.args, workerData.options, workerData.defaultEnv, workerData.disposables)
+        .then((res) => {
+            if (!parentPort) {
+                throw new Error('Not in a worker thread');
+            }
+            parentPort.postMessage({ res });
+        })
+        .catch((err) => {
+            if (!parentPort) {
+                throw new Error('Not in a worker thread');
+            }
+            parentPort.postMessage({ err });
+        });
+}

src/client/common/process/worker/shellExecWorker.ts

@@ -1,16 +1,18 @@
-import { parentPort, workerData } from 'worker_threads';
+import { isMainThread, parentPort, workerData } from 'worker_threads';
 import { workerShellExec } from './workerRawProcessApis';
 
-workerShellExec(workerData.command, workerData.options, workerData.defaultEnv, workerData.disposables)
-    .then((res) => {
-        if (!parentPort) {
-            throw new Error('Not in a worker thread');
-        }
-        parentPort.postMessage(res);
-    })
-    .catch((ex) => {
-        if (!parentPort) {
-            throw new Error('Not in a worker thread');
-        }
-        parentPort.postMessage(ex);
-    });
+if (!isMainThread) {
+    workerShellExec(workerData.command, workerData.options, workerData.defaultEnv, workerData.disposables)
+        .then((res) => {
+            if (!parentPort) {
+                throw new Error('Not in a worker thread');
+            }
+            parentPort.postMessage(res);
+        })
+        .catch((ex) => {
+            if (!parentPort) {
+                throw new Error('Not in a worker thread');
+            }
+            parentPort.postMessage(ex);
+        });
+}