Помнится, когда-то я уже боролся с проблемой зависания потока вызова внешней программы (javac). Так вот то решение (JAVA-JAV-002924) прекрасно работает с компилятором, но когда я пытаюсь вызвать другую программу, а в моём случае это mysqldump, поток опять виснет Самое интересное, что при пошаговом прохождении кода, всё работает. Ну и, как говорится, пожалуйста, помогите.

Executer.java (хотя в статье фака он есть)

Код

package org.simanyay.jizer.kernel; import java.util.*; import java.io.*; /**  * Executes external program   *   * @author simanyay  * @see http://www.javaworld.com/javaworld/jw-12-2000/jw-1229-traps_p.html  */ class Executer {     private List<String> err_output; // Error output     private List<String> nor_output; // Normal output     private StringBuffer console_output;     private int exit_value;          private final int ARRAY = 1;     private final int STRING = 2;          public void execute(String cmd) throws Exception {         genericExec(cmd, STRING);     }          public void execute(String[] cmd) throws Exception {         genericExec(cmd, ARRAY);     }          private void genericExec(Object cmd, int type) throws Exception {         Runtime runtime = Runtime.getRuntime();         Process proc = null;                  if(type == STRING) {             proc = runtime.exec((String) cmd);         } else if(type == ARRAY) {             proc = runtime.exec((String[]) cmd);         } else throw new IllegalArgumentException();                  Streamer err_stream = new Streamer(proc.getErrorStream());         Streamer out_stream = new Streamer(proc.getInputStream());                  err_stream.run();         out_stream.run();                  exit_value = proc.waitFor();                  console_output = new StringBuffer();                  for(String s : err_stream.getOutput()) {             console_output.append(s + "\n");         }                  for(String s : out_stream.getOutput()) {             console_output.append(s + "\n");         }     }     public int getExitValue() {         return exit_value;     }     public StringBuffer getConsoleOutput() {         return console_output;     } } /**  * Every stream (stdin or stderr) should have it's own thread because some native platforms  * provide limited buffer size for input and output streams, so failure to promptly write the  * input stream or read the output stream of the subproccess may cause the subproccess to block,  * and even deadlock.  *   * @author simanyay  */ class Streamer extends Thread {     private InputStream input;     private List<String> output;     public Streamer(InputStream in) {         input = in;         output = new ArrayList<String>();     }     public List<String> getOutput() {         return output;     }          public void run() {         output.clear();                  try {             BufferedReader reader = new BufferedReader(new InputStreamReader(input));             String line = null;             if(!reader.ready()) return;             while((line = reader.readLine()) != null) {                 output.add(line);             }         } catch(IOException ioe) {             ioe.printStackTrace();         }     } }

ну и собственно сам вызов (метод не закончен, там будут подставляться разные имена бд и юзернэймы, а результаты сливаться в файл и т.д., но это не суть важно)

Код

public boolean exportState(String state) {     try {         String cmd = "mysqldump -X demo -u root --password=\"somepassword\"";                      Executer console = new Executer();                  console.execute(cmd);         System.out.println(console.getConsoleOutput());                  if(console.getExitValue() == 0) return true;         else return false;     } catch(Exception e) {         e.printStackTrace();         return false;     } }

Проблема здесь:

Код

if (!reader.ready()) return;

Mysqldump нужно определенное время на формирование вывода и при первом вызове reader.ready() читать еще нечего, а вызов этот неблокирующий. reader.readLine() же видимо блокирует поток до тех пор, пока не поступят данные (или поток не закроется). А в остальном все работает как часы

Это сообщение отредактировал(а) tux - 17.7.2005, 08:14