test(pthreads-test): use standard --threads flag

Author: thewtex

packages/core/typescript/itk-wasm/test/node/pipeline/run-pipeline-node-test.js

@@ -10,7 +10,7 @@ import {
   InterfaceTypes
 } from '../../../dist/index-node.js'
 
-function readCthead1 () {
+function readCthead1() {
   const testInputImageDir = path.resolve(
     'test',
     'pipelines',
@@ -49,7 +49,7 @@ function readCthead1 () {
   return image
 }
 
-function readCow () {
+function readCow() {
   const testInputMeshDir = path.resolve(
     'test',
     'pipelines',
@@ -88,7 +88,7 @@ function readCow () {
   return mesh
 }
 
-function readLinearTransform () {
+function readLinearTransform() {
   const testInputTransformDir = path.resolve(
     'test',
     'pipelines',
@@ -126,7 +126,7 @@ function readLinearTransform () {
   return transformList
 }
 
-function readCompositeTransform () {
+function readCompositeTransform() {
   const testInputTransformDir = path.resolve(
     'test',
     'pipelines',
@@ -651,7 +651,7 @@ test('runPipelineNode runs pthreads-enabled pipeline', async (t) => {
     'pthreads-pipeline',
     'pthreads-test'
   )
-  const args = ['--memory-io', '--number-of-threads', '4', '0']
+  const args = ['--memory-io', '--threads', '3', '0']
   const desiredOutputs = [{ type: InterfaceTypes.JsonCompatible }]
   const inputs = []
 

packages/core/typescript/itk-wasm/test/pipelines/pthreads-pipeline/pthreads-test.cxx

@@ -37,14 +37,13 @@ int main( int argc, char * argv[] )
 {
   itk::wasm::Pipeline pipeline("pthreads-test", "A pipeline to test pthreads support", argc, argv);
 
-  int numberOfThreads = 4;
-  pipeline.add_option("-n,--number-of-threads", numberOfThreads, "The number of threads to use");
-
   itk::wasm::OutputTextStream outputJson;
   pipeline.add_option("output-json", outputJson, "The output json with test results")->type_name("OUTPUT_JSON");
 
   ITK_WASM_PARSE(pipeline);
 
+  const int numberOfThreads = pipeline.get_threads();
+
   // Based on: https://bytecodealliance.org/articles/wasi-threads
   pthread_t threads[512];
   size_t thread_ids[512];