From 2b1a9d67a05e31f8c7138348c210213023d963c1 Mon Sep 17 00:00:00 2001
From: xkeyC <3334969096@qq.com>
Date: Sun, 25 Feb 2024 11:10:21 +0800
Subject: [PATCH] =?UTF-8?q?win32job=20=E6=94=B9=E4=B8=BA=20assign=5Fproces?=
 =?UTF-8?q?s?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 rust/src/api/process_api.rs | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/rust/src/api/process_api.rs b/rust/src/api/process_api.rs
index 15b6713..7ac562f 100644
--- a/rust/src/api/process_api.rs
+++ b/rust/src/api/process_api.rs
@@ -2,6 +2,7 @@ use std::sync::Arc;
 use tokio::io::{AsyncBufReadExt, BufReader};
 use crate::frb_generated::StreamSink;
 
+
 pub async fn start_process(
     executable: String,
     arguments: Vec<String>,
@@ -24,10 +25,16 @@ pub async fn start_process(
     let mut info = job.query_extended_limit_info().unwrap();
     info.limit_kill_on_job_close();
     job.set_extended_limit_info(&mut info).unwrap();
-    job.assign_current_process().unwrap();
 
+    let job_arc = Arc::from(job);
 
     if let Ok(mut child) = command.spawn() {
+        {
+            let raw_handle = child.raw_handle();
+            if raw_handle.is_some() {
+                job_arc.assign_process(raw_handle.unwrap() as isize).unwrap();
+            }
+        }
         let stdout = child.stdout.take().expect("Failed to open stdout");
         let stderr = child.stderr.take().expect("Failed to open stderr");
         let output_task = tokio::spawn(process_output(stdout, stream_sink_arc.clone()));