How to know if the process has terminated while processing the inputstream and when should I call process.waitFor() or process.exitValue()?

Question

I am trying to execute commands using Java. So when I try to convert the process Inputstream to string using BufferedReader, the code works if I call process.waitFor() after processing the inputstream to string. But when I try to convert the process input stream using ByteArrayOutputStream to string, the results are not returned if I write process.waitFor() after processing the inputstream to string. It works only process.waitFor is written before inputstream.isavailable(). I don't understand why this is behaving like this? Also I want to know how to determing the buffer array size incase of using ByteArrayStream. I am trying to use isavailable() to know to number of bytes.

``ProcessBuilder pb = new ProcessBuilder();

    String cmd = "ls -l /Users/uma/data";
    pb.command("bash", "-c",cmd);
    
    try {
        Process process = pb.start();
        StringBuilder output = new StringBuilder();
        
        BufferedReader reader = new BufferedReader(
                new InputStreamReader(process.getInputStream()));

        String line;
        while ((line = reader.readLine()) != null) {
            output.append(line + "\n");
        }
        intexitVal = process.waitFor();

        if (exitVal == 0) {
            System.out.println("Success!");
            System.out.println(output);
            System.exit(0);
        } else {
              try (final BufferedReader b = new BufferedReader(new InputStreamReader(process.getErrorStream()))) {
                    String errorline;
                    if ((errorline = b.readLine()) != null)
                        System.out.println(errorline);
                } catch (final IOException e) {
                    e.printStackTrace();
                }   
        }
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    `


``ProcessBuilder pb = new ProcessBuilder();
        
        String cmd = "ls -l /Users/uma/data";
        pb.command("bash", "-c",cmd);
        
        try {
            Process process = pb.start();
            int exitVal = process.waitFor();
            InputStream is = process.getInputStream();
             ByteArrayOutputStream result = new ByteArrayOutputStream();
                byte[] buffer = newbyte[is.available()];
                int length;
                while ((length = is.read(buffer)) != -1) {
                    result.write(buffer, 0, length);
                }
                String output = result.toString();
            if (exitVal == 0) {
                System.out.println("Success!");
                System.out.println(output);
                System.exit(0);
            } else {
                  try (final BufferedReader b = new BufferedReader(new InputStreamReader(process.getErrorStream()))) {
                        String errorline;
                        if ((errorline = b.readLine()) != null)
                            System.out.println(errorline);
                    } catch (final IOException e) {
                        e.printStackTrace();
                    }   
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }`

How to determine the buffer size? Also when should I call waitFor()?

score 0 · Accepted Answer · answered Feb 06 '23 at 09:21

0

waitFor() waits for the target process to exit, and returns the exit code given by it. You can use it to wait for the program to stop, before logging any errors or checking the exit code.

As for the buffer size, I recommend using is.readAllBytes() if you just want to get the entire input stream as a byte array. To then convert that to a string, use new String(is.readAllBytes());.

If you just want to stream the content of the input stream into another stream (such as System.out or System.err), use this:

InputStream is = /* get input stream */;
byte[] buffer = new byte[128];
int read;
while((read = is.read(buffer)) != -1) {
    System.out.write(buffer, 0, read);
}

This will just write the entire is input stream into System.out, you can configure or change this as you'd like.

answered Feb 06 '23 at 09:21

0x150

589
2
11

I am using Java 8 where readAllBytes is not available. Is there any alternate for this method? Also do you have any idea on using available method for buffer size? Is it advisable to use that? – Umabharathi Manikandan Feb 06 '23 at 09:35
In my case, is.available is returning zero if waitFor is called at the end. Its returning bytes only if I call waitFor() before the available() method. Any idea on how this works? – Umabharathi Manikandan Feb 06 '23 at 09:41
The program might've not logged anything in the time that passed between starting and calling .available(), so the InputStream is empty. Only if the program logs something, does the InputStream get filled. With .waitFor(), the program waits until the other program is finished running, in which case the InputStream would be filled. – 0x150 Feb 06 '23 at 10:31

How to know if the process has terminated while processing the inputstream and when should I call process.waitFor() or process.exitValue()?

1 Answers1