From 09096deb0be9acfbf634b8fabb0d5a94b3cc8eb6 Mon Sep 17 00:00:00 2001 From: Fabrice Reix Date: Tue, 29 Oct 2024 14:44:43 +0100 Subject: [PATCH] TEST DO NOT MERGE --- packages/hurl/src/parallel/runner.rs | 12 ++++++------ packages/hurl/src/parallel/worker.rs | 1 + 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/packages/hurl/src/parallel/runner.rs b/packages/hurl/src/parallel/runner.rs index 68a27da86a3..1127f601e6b 100644 --- a/packages/hurl/src/parallel/runner.rs +++ b/packages/hurl/src/parallel/runner.rs @@ -278,12 +278,12 @@ impl ParallelRunner { // We gracefully shut down workers, by dropping the sender and wait for each thread workers // to join. - drop(self.tx.take()); - for worker in &mut self.workers { - if let Some(thread) = worker.0.take_thread() { - thread.join().unwrap(); - } - } + // drop(self.tx.take()); + // for worker in &mut self.workers { + // if let Some(thread) = worker.0.take_thread() { + // thread.join().unwrap(); + // } + // } // All jobs have been executed, we sort results by sequence number to get the same order // as the input jobs list. diff --git a/packages/hurl/src/parallel/worker.rs b/packages/hurl/src/parallel/worker.rs index 56954770723..760c5b6bdbb 100644 --- a/packages/hurl/src/parallel/worker.rs +++ b/packages/hurl/src/parallel/worker.rs @@ -142,6 +142,7 @@ impl Worker { } /// Takes the thread out of the worker, leaving a None in its place. + #[allow(dead_code)] pub fn take_thread(&mut self) -> Option> { self.thread.take() }