shkong/clash-verge-rev
1
0
Fork 0
mirror of https://github.com/clash-verge-rev/clash-verge-rev synced 2025-05-06 14:43:44 +08:00
Code Packages Projects Releases Activity

perf: simplify code logic and improve efficiency

Browse Source
This commit is contained in:
wonfen 2025-03-23 02:16:06 +08:00
parent bc39d56b0f
commit 9b04721b3d
1 changed files with 47 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

83
src-tauri/src/core/core.rs
View File

@ -784,83 +784,94 @@ impl CoreManager {
/// 检查系统中是否存在同名进程 /// 检查系统中是否存在同名进程
async fn check_existing_processes(&self, process_name: &str) -> Result<Vec<u32>> { async fn check_existing_processes(&self, process_name: &str) -> Result<Vec<u32>> {
println!("[进程检查] 检查系统中是否存在进程: {}", process_name); println!("[进程检查] 检查系统中是否存在进程: {}", process_name);
#[cfg(target_os = "windows")] #[cfg(target_os = "windows")]
{ {
use std::process::Command; use std::process::Command;
println!("[进程检查] Windows系统，使用tasklist命令"); println!("[进程检查] Windows系统，使用tasklist命令");
let output = Command::new("tasklist") let output = Command::new("tasklist")
.args(["/FO", "CSV", "/NH"]) .args(["/FO", "CSV", "/NH"])
.output()?; .output()?;
let output = String::from_utf8_lossy(&output.stdout); let output = String::from_utf8_lossy(&output.stdout);
let mut pids = Vec::new();
for line in output.lines() { let pids: Vec<u32> = output
if line.contains(process_name) { .lines()
.filter(|line| line.contains(process_name))
.filter_map(|line| {
println!("[进程检查] 发现匹配行: {}", line); println!("[进程检查] 发现匹配行: {}", line);
let parts: Vec<&str> = line.split(',').collect(); let parts: Vec<&str> = line.split(',').collect();
if parts.len() >= 2 { if parts.len() >= 2 {
let pid_str = parts[1].trim_matches('"'); let pid_str = parts[1].trim_matches('"');
if let Ok(pid) = pid_str.parse::<u32>() { pid_str.parse::<u32>().ok().map(|pid| {
println!("[进程检查] 发现进程 PID: {}", pid); println!("[进程检查] 发现进程 PID: {}", pid);
pids.push(pid); pid
} })
} else {
None
} }
} })
} .collect();
println!("[进程检查] 共发现 {} 个相关进程", pids.len()); println!("[进程检查] 共发现 {} 个相关进程", pids.len());
Ok(pids) Ok(pids)
} }
#[cfg(target_os = "linux")] #[cfg(target_os = "linux")]
{ {
use std::process::Command; use std::process::Command;
println!("[进程检查] Linux系统，使用pgrep命令"); println!("[进程检查] Linux系统，使用pgrep命令");
let output = Command::new("pgrep").arg("-f").arg(process_name).output()?; let output = Command::new("pgrep")
.arg("-f")
.arg(process_name)
.output()?;
let output = String::from_utf8_lossy(&output.stdout); let output = String::from_utf8_lossy(&output.stdout);
let mut pids = Vec::new();
for line in output.lines() {
if let Ok(pid) = line.trim().parse::<u32>() {
println!("[进程检查] 发现进程 PID: {}", pid);
pids.push(pid);
}
}
let pids: Vec<u32> = output
.lines()
.filter_map(|line| {
line.trim().parse::<u32>().ok().map(|pid| {
println!("[进程检查] 发现进程 PID: {}", pid);
pid
})
})
.collect();
println!("[进程检查] 共发现 {} 个相关进程", pids.len()); println!("[进程检查] 共发现 {} 个相关进程", pids.len());
Ok(pids) Ok(pids)
} }
#[cfg(target_os = "macos")] #[cfg(target_os = "macos")]
{ {
use std::process::Command; use std::process::Command;
println!("[进程检查] macOS系统，使用ps命令"); println!("[进程检查] macOS系统，使用ps命令");
let output = Command::new("ps") let output = Command::new("ps")
.args(["-ax", "-o", "pid,command"]) .args(["-ax", "-o", "pid,command"])
.output()?; .output()?;
let output = String::from_utf8_lossy(&output.stdout); let output = String::from_utf8_lossy(&output.stdout);
let mut pids = Vec::new();
for line in output.lines() { let pids: Vec<u32> = output
if line.contains(process_name) { .lines()
.filter(|line| line.contains(process_name))
.filter_map(|line| {
println!("[进程检查] 发现匹配行: {}", line); println!("[进程检查] 发现匹配行: {}", line);
let parts: Vec<&str> = line.split_whitespace().collect(); let parts: Vec<&str> = line.split_whitespace().collect();
if !parts.is_empty() { if !parts.is_empty() {
if let Ok(pid) = parts[0].parse::<u32>() { parts[0].parse::<u32>().ok().map(|pid| {
println!("[进程检查] 发现进程 PID: {}", pid); println!("[进程检查] 发现进程 PID: {}", pid);
pids.push(pid); pid
} })
} else {
None
} }
} })
} .collect();
println!("[进程检查] 共发现 {} 个相关进程", pids.len()); println!("[进程检查] 共发现 {} 个相关进程", pids.len());
Ok(pids) Ok(pids)
} }