Reimplement parallel runtime with worker threads

compatibility/cck_spec.ts

@@ -19,8 +19,6 @@ const CCK_IMPLEMENTATIONS_PATH = 'compatibility/features'
 const UNSUPPORTED = [
   // we aren't fully compliant yet for global hooks
   'global-hooks-attachments',
-  'global-hooks-beforeall-error',
-  'global-hooks-afterall-error',
   // not a test sample
   'test-run-exception',
 ]

compatibility/features/global-hooks-afterall-error/global-hooks-afterall-error.ts

@@ -0,0 +1,25 @@
+import { When, BeforeAll, AfterAll } from '../../../src'
+
+BeforeAll({}, function () {
+  // no-op
+})
+
+BeforeAll({}, function () {
+  // no-op
+})
+
+When('a step passes', function () {
+  // no-op
+})
+
+AfterAll({}, function () {
+  // no-op
+})
+
+AfterAll({}, function () {
+  throw new Error('AfterAll hook went wrong')
+})
+
+AfterAll({}, function () {
+  // no-op
+})

compatibility/features/global-hooks-beforeall-error/global-hooks-beforeall-error.ts

@@ -0,0 +1,25 @@
+import { When, BeforeAll, AfterAll } from '../../../src'
+
+BeforeAll({}, function () {
+  // no-op
+})
+
+BeforeAll({}, function () {
+  throw new Error('BeforeAll hook went wrong')
+})
+
+BeforeAll({}, function () {
+  // no-op
+})
+
+When('a step passes', function () {
+  // no-op
+})
+
+AfterAll({}, function () {
+  // no-op
+})
+
+AfterAll({}, function () {
+  // no-op
+})

features/before_after_all_hooks_context.feature

@@ -88,6 +88,7 @@ Feature: Before/After All Hooks Context
     When I run cucumber-js
     Then it passes
 
+  @parallel
   Scenario: Works the same way on the parallel runtime
     Given a file named "features/support/hooks.js" with:
       """

features/dryrun_mode.feature

@@ -72,7 +72,7 @@ Feature: Dryrun mode
     When I run cucumber-js with `--dry-run`
     Then it passes
 
-  @spawn
+  @parallel @spawn
   Scenario: hooks should not execute in dry run, parallel runtime
     Given a file named "features/step_definitions/cucumber_steps.js" with:
     """

features/esm.feature

@@ -43,6 +43,7 @@ Feature: ES modules support
     Then it runs 2 scenarios
     And it passes
 
+  @parallel
   Scenario: native modules work with parallel runtime
     Given a file named "features/a.feature" with:
       """

features/loaders.feature

@@ -37,6 +37,7 @@ Feature: ESM loaders support
     When I run cucumber-js with `--loader ts-node/esm --import features/steps.ts`
     Then it passes
 
+  @parallel
   Scenario: parallel runtime
     When I run cucumber-js with `--loader ts-node/esm --import features/steps.ts --parallel 1`
     Then it passes

features/parallel.feature

@@ -1,3 +1,4 @@
+@parallel
 Feature: Running scenarios in parallel
 
   Scenario: running in parallel can improve speed if there are async operations

features/parallel_custom_assign.feature

@@ -1,3 +1,4 @@
+@parallel
 Feature: Running scenarios in parallel with custom assignment
 
   @spawn

features/retry.feature

@@ -100,6 +100,7 @@ Feature: Retry flaky tests
     And scenario "Flaky" attempt 1 step "Given a flaky step" has status "passed"
     And it passes
 
+  @parallel
   Scenario: retrying a flaky test will eventually make it pass (parallel)
     Given a file named "features/a.feature" with:
       """

features/step_definition_snippets_custom_syntax.feature

@@ -73,6 +73,7 @@ Feature: step definition snippets custom syntax
       | async-await | ->                           | 'pending'              |
       | synchronous | ->                           | 'pending'              |
 
+  @parallel
   Scenario: Custom snippet syntax works in parallel runtime
     When I run cucumber-js with `--parallel 2 --format-options '{"snippetInterface": "async-await", "snippetSyntax": "./coffeescript_syntax.js"}'`
     Then it fails

src/runtime/coordinator.ts

@@ -24,15 +24,32 @@ export class Coordinator implements Runtime {
       },
     } satisfies Envelope)
 
-    const assembledTestCases = await assembleTestCases(
-      this.testRunStartedId,
-      this.eventBroadcaster,
-      this.newId,
-      this.sourcedPickles,
-      this.supportCodeLibrary
-    )
+    await this.adapter.setup()
 
-    const success = await this.adapter.run(assembledTestCases)
+    const successByPhase = {
+      beforeAllHooks: false,
+      testCases: false,
+      afterAllHooks: false,
+    }
+    successByPhase.beforeAllHooks = await this.adapter.runBeforeAllHooks()
+    if (successByPhase.beforeAllHooks) {
+      const assembledTestCases = await assembleTestCases(
+        this.testRunStartedId,
+        this.eventBroadcaster,
+        this.newId,
+        this.sourcedPickles,
+        this.supportCodeLibrary
+      )
+      successByPhase.testCases =
+        await this.adapter.runTestCases(assembledTestCases)
+    }
+    successByPhase.afterAllHooks = await this.adapter.runAfterAllHooks()
+    const success =
+      successByPhase.beforeAllHooks &&
+      successByPhase.testCases &&
+      successByPhase.afterAllHooks
+
+    await this.adapter.teardown()
 
     this.eventBroadcaster.emit('envelope', {
       testRunFinished: {

src/runtime/make_runtime.ts

@@ -7,9 +7,9 @@ import { SupportCodeLibrary } from '../support_code_library_builder/types'
 import FormatterBuilder from '../formatter/builder'
 import { FormatOptions } from '../formatter'
 import { Runtime } from './types'
-import { ChildProcessAdapter } from './parallel/adapter'
 import { InProcessAdapter } from './serial/adapter'
 import { Coordinator } from './coordinator'
+import { WorkerThreadsAdapter } from './parallel/adapter'
 
 export async function makeRuntime({
   environment,
@@ -62,7 +62,7 @@ async function makeAdapter(
   newId: () => string
 ) {
   if (options.parallel > 0) {
-    return new ChildProcessAdapter(
+    return new WorkerThreadsAdapter(
       testRunStartedId,
       environment,
       logger,