MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-01-06 03:21:12 +07:00
Code Issues Packages Projects Releases Wiki Activity

optimize processing in fork mode

Browse Source
This commit is contained in:
Anna.Kozlova
2018-07-20 12:31:21 +02:00
parent 40a84be48d
commit fa3b7eda04
1 changed files with 13 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
java/java-runtime/src/com/intellij/rt/execution/testFrameworks/ForkedByModuleSplitter.java
View File

@@ -23,6 +23,7 @@ import java.util.jar.JarOutputStream;
import java.util.jar.Manifest;
import java.util.zip.ZipOutputStream;
/** @noinspection CallToPrintStackTrace*/
public abstract class ForkedByModuleSplitter {
protected final ForkedDebuggerHelper myForkedDebuggerHelper = new ForkedDebuggerHelper();
protected final String myWorkingDirsPath;
@@ -107,39 +108,25 @@ public abstract class ForkedByModuleSplitter {
private static Runnable createInputReader(final InputStream inputStream, final PrintStream outputStream, final boolean[] stopped) {
return new Runnable() {
char[] buf = new char[8192];
public void run() {
final InputStreamReader inputReader;
try {
inputReader = new InputStreamReader(inputStream, "UTF-8");
}
catch (UnsupportedEncodingException e) {
return;
}
final BufferedReader inputReader = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));
try {
while (true) {
if (stopped[0]) break;
try {
while (true) {
if (stopped[0]) break;
int n;
try {
while (inputReader.ready() && (n = inputReader.read(buf)) > 0) {
outputStream.print(new String(buf, 0, n));
}
}
catch (IOException e) {
e.printStackTrace();
String line = inputReader.readLine();
if (line == null) break;
outputStream.print(line);
}
}
}
finally {
try {
finally {
inputReader.close();
}
catch (IOException e) {
e.printStackTrace();
}
}
catch (UnsupportedEncodingException ignored) { }
catch (IOException e) {
e.printStackTrace();
}
}
};