Merge pull request #1361 from thewtex/pthread-available

pthread available

Author: thewtex

packages/core/typescript/itk-wasm/cypress/e2e/pipeline/pthread-support-available.cy.ts

@@ -0,0 +1,21 @@
+import { demoServer, pipelineBaseUrl, pipelineWorkerUrl } from '../common'
+
+describe('pthreadSupportAvailable', () => {
+  beforeEach(() => {
+    cy.visit(demoServer)
+    cy.window().then(async (win) => {
+      const itk = win.itk
+      itk.setPipelineWorkerUrl(pipelineWorkerUrl)
+      itk.setPipelinesBaseUrl(pipelineBaseUrl)
+    })
+  })
+
+  it('reports whether pthread support is available', () => {
+    cy.window().then(async (win) => {
+      const itk = win.itk
+
+      const pthreadSupportAvailable = itk.pthreadSupportAvailable()
+      expect(pthreadSupportAvailable).to.equal(false)
+    })
+  })
+})

packages/core/typescript/itk-wasm/src/pipeline/index-common.ts

@@ -1,3 +1,5 @@
+export { default as pthreadSupportAvailable } from './pthread-support-available.js'
+
 export type { default as ItkWasmEmscriptenModule } from './itk-wasm-emscripten-module.js'
 
 export type { default as PipelineInput } from './pipeline-input.js'

packages/core/typescript/itk-wasm/src/pipeline/index.ts

@@ -1,4 +1,4 @@
-// itk-wasm Browser pipeline functions
+// ITK-Wasm Browser pipeline functions
 
 export { default as runPipeline } from './run-pipeline.js'
 export { default as createWebWorker } from './create-web-worker.js'

packages/core/typescript/itk-wasm/src/pipeline/pthread-support-available.ts

@@ -0,0 +1,25 @@
+function pthreadSupportAvailable(): boolean {
+  const haveSharedArrayBuffer =
+    typeof globalThis.SharedArrayBuffer === 'function'
+
+  // Emscripten ENVIRONMENT_IS_NODE
+  const isNode =
+    typeof process === 'object' &&
+    typeof process.versions === 'object' &&
+    typeof process.versions.node === 'string' &&
+    // @ts-ignore: ts(2339)
+    process.type !== 'renderer'
+
+  const isCrossOriginIsolated =
+    typeof crossOriginIsolated !== 'undefined'
+      ? crossOriginIsolated
+      : globalThis.crossOriginIsolated || false
+
+  if (isNode) {
+    return haveSharedArrayBuffer
+  }
+
+  return haveSharedArrayBuffer && isCrossOriginIsolated
+}
+
+export default pthreadSupportAvailable

packages/core/typescript/itk-wasm/test/node/pipeline/pthread-support-available-test.js

@@ -0,0 +1,7 @@
+import test from 'ava'
+
+import { pthreadSupportAvailable } from '../../../dist/index-node.js'
+
+test('node pthread support available', (t) => {
+  t.truthy(pthreadSupportAvailable())
+})

packages/core/typescript/itk-wasm/test/pipelines/typescript/package.json

@@ -36,15 +36,16 @@
     "itk-wasm": "workspace:*"
   },
   "devDependencies": {
+    "@itk-wasm/demo-app": "workspace:*",
     "@itk-wasm/image-io": "workspace:*",
     "@itk-wasm/mesh-io": "workspace:*",
     "@itk-wasm/transform-io": "workspace:*",
-    "@itk-wasm/demo-app": "workspace:*",
     "@types/node": "^20.2.5",
     "esbuild": "^0.25.0",
     "shx": "^0.3.4",
     "typescript": "^5.3.2",
     "vite": "^4.5.11",
+    "vite-plugin-cross-origin-isolation": "^0.1.6",
     "vite-plugin-static-copy": "^0.17.0"
   }
-}
+}

packages/core/typescript/itk-wasm/test/pipelines/typescript/vite.config.js

@@ -1,5 +1,6 @@
 import { defineConfig } from 'vite'
 import { viteStaticCopy } from 'vite-plugin-static-copy'
+import crossOriginIsolation from 'vite-plugin-cross-origin-isolation'
 import path from 'path'
 
 const base = process.env.VITE_BASE_URL || '/'
@@ -21,6 +22,8 @@ export default defineConfig({
     exclude: ['itk-wasm', '@itk-wasm/image-io', '@itk-wasm/mesh-io', '@itk-wasm/transform-io', '@thewtex/zstddec']
   },
   plugins: [
+    // wasm threading
+    crossOriginIsolation(),
     // put lazy loaded JavaScript and Wasm bundles in dist directory
     viteStaticCopy({
       targets: [