slhaf/Partner
1
0
Fork 0
mirror of https://github.com/slhaf/Partner.git synced 2026-05-12 16:53:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(runner): change stdout/stderr reading thread into virtual thread in CommandExecutionService

Browse Source
This commit is contained in:
slhafzjw
2026-03-18 16:18:10 +08:00
parent 664bd5a0fb
commit 7f4b82204a
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
Partner-Core/src/main/java/work/slhaf/partner/core/action/runner/execution/CommandExecutionService.java
View File

@@ -7,10 +7,14 @@ import java.io.InputStreamReader;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
public class CommandExecutionService { public class CommandExecutionService {
private ExecutorService readerExecutor = Executors.newVirtualThreadPerTaskExecutor();
public String[] buildFileExecutionCommands(String launcher, Map<String, Object> params, String absolutePath) { public String[] buildFileExecutionCommands(String launcher, Map<String, Object> params, String absolutePath) {
int paramSize = params == null ? 0 : params.size(); int paramSize = params == null ? 0 : params.size();
String[] commands = new String[paramSize + 2]; String[] commands = new String[paramSize + 2];
@@ -57,8 +61,8 @@ public class CommandExecutionService {
} }
}); });
stdoutThread.start(); readerExecutor.execute(stdoutThread);
stderrThread.start(); readerExecutor.execute(stderrThread);
int exitCode = process.waitFor(); int exitCode = process.waitFor();
stdoutThread.join(); stdoutThread.join();
@@ -81,4 +85,8 @@ public class CommandExecutionService {
private String total; private String total;
private List<String> resultList; private List<String> resultList;
} }
@Data
public static class CommandSessionResult {
}
} }