конец нити, что застрял в InputStream.read() петли

Question

Я запуска приложения CMD, который выводит в System.out через этот SyncPipe Runnable:

public class SyncPipe implements Runnable { 

    private final InputStream is; 
    private final OutputStream os; 

    public SyncPipe(InputStream is, OutputStream os) { 
     this.is = is; 
     this.os = os; 
    } 

    public void run() { 
     try { 
      final byte[] buffer = new byte[1024]; 
      for (int length = 0; (length = is.read(buffer)) != -1;) 
       os.write(buffer, 0, length); 
      System.out.print("stopped"); 
     } catch (Exception ex) { 
      ex.printStackTrace(); 
     } 
    } 

} 

я начала RunIt с cmd = "C:/bin/read.exe -f D:/test.jpg"

private class RunIt implements Runnable { 

    public int p; 
    public String cmd; 

    public RunIt (int p, String cmd) { 
     this.p = p; 
     this.cmd = cmd; 
    } 

    public void run() { 
     ProcessBuilder pb = new ProcessBuilder("cmd"); 
     try { 
      process = pb.start(); 
      (new Thread(new SyncPipe(process.getErrorStream(), System.err))).start(); 
      (new Thread(new SyncPipe(process.getInputStream(), System.out))).start(); 
      OutputStream out = process.getOutputStream(); 
      out.write((cmd + "\r\n").getBytes()); 
      out.flush(); 
      out.close(); 

      try { 
       process.waitFor(); 
      } catch (InterruptedException e) { 
       e.printStackTrace(); 
      } 

      println("Stopped using %d.", p); 
     } catch (IOException ex) { 
      ex.printStackTrace(); 
     } 
    } 

} 

Мой вопрос сейчас: Как я могу сделать (new Thread(new SyncPipe(process.getErrorStream(), System.err))) die? Предоставляя SyncPipe логическую переменную stop, устанавливая ее true во время выполнения и проверяя ее с помощью for (int length = 0; (length = is.read(buffer)) != -1 && !stop;), не удалось сделать трюк.

Большое спасибо.

---

Я закончил работу вокруг этого @Gray. Он работает сейчас:

public void run() { 
    try { 
     final byte[] buffer = new byte[1024]; 
     do 
      if (is.available() > 0) { 
       int length = is.read(buffer); 
       if (length != -1) 
        os.write(buffer, 0, length); 
       else 
        stop = true; 
      } 
     while (!stop); 
    } catch (Exception ex) { 
     ex.printStackTrace(); 
    } 
} 

Answer 1

Поток будет читать EOS и выйти, когда основной процесс завершится. Вам не нужно делать ничего особенного в этом.

EDIT Мне кажется, прочитав ваши комментарии к другим ответам, ваша настоящая проблема заключается в прекращении процесса. Эти потоки будут отклеиваться, как только это произойдет. Вы атакуете неправильный конец проблемы.

Answer 2

Мой вопрос теперь: Как я могу сделать (новый Thread (новый SyncPipe (process.getErrorStream(), System.err))) умереть?

Вам нужно будет закрыть входной поток из-под него, я верю. Я подозреваю, что он заблокирован в режиме чтения и без значения переменной stop (даже если правильно volatile) получит разблокированный поток для чтения.

Вы будете нуждаться, чтобы сделать что-то вроде:

InputStream is = process.getInputStream(); 
InputStream es = process.getErrorStream(); 
... 
is.close(); 
es.close(); 

код будет выглядеть примерно следующим образом. Я не уверен, возвращается ли ваш звонок waitFor() или нет.

InputStream is = process.getInputStream(); 
InputStream es = process.getErrorStream(); 
(new Thread(new SyncPipe(es, System.err))).start(); 
(new Thread(new SyncPipe(is, System.out))).start(); 
try { 
    OutputStream out = process.getOutputStream(); 
    out.write((cmd + "\r\n").getBytes()); 
    out.flush(); 
    out.close(); 
    try { 
     process.waitFor(); 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    } 
} finally { 
    is.close(); 
    es.close(); 
} 

Другой ответ может быть использование метода available() на InputStream, так что вы можете петлю и проверить stop флаг. См этот ответ: https://stackoverflow.com/a/1089079/179850

Answer 3

InputStream#read() состояний

Этот метод блоки до тех пор, входные данные не доступны, конец потока обнаруживается, или исключение.

Итак, когда вы идете в вашу for петлю

for (int length = 0; (length = is.read(buffer)) != -1;) 
    os.write(buffer, 0, length); 

не сможет выйти до конца потока не будет достигнуто, то есть. процесс останавливается или вы сами закрываете потоки.

Если цель SyncPipe состоит в том, чтобы передать содержимое вашим стандартным потокам вывода/ошибок, почему вы хотите остановить запуск Thread?