深入研究java.lang.Process类&Process的的waitFor()造成的阻塞

一、概述

Process类是一个抽象类（所有的方法均是抽象的），封装了一个进程（即一个执行程序）。

Process 类提供了执行从进程输入、执行输出到进程、等待进程完成、检查进程的退出状态以及销毁（杀掉）进程的方法。

ProcessBuilder.start() 和 Runtime.exec 方法创建一个本机进程，并返回 Process 子类的一个实例，该实例可用来控制进程并获取相关信息。

创建进程的方法可能无法针对某些本机平台上的特定进程很好地工作，比如，本机窗口进程，守护进程，Microsoft Windows 上的 Win16/DOS 进程，或者 shell 脚本。创建的子进程没有自己的终端或控制台。它的所有标准 io（即 stdin，stdout，stderr）操作都将通过三个流 (getOutputStream()，getInputStream()，getErrorStream())
重定向到父进程。父进程使用这些流来提供到子进程的输入和获得从子进程的输出。因为有些本机平台仅针对标准输入和输出流提供有限的缓冲区大小，如果读写子进程的输出流或输入流迅速出现失败，则可能导致子进程阻塞，甚至产生死锁。

当没有 Process 对象的更多引用时，不是删掉子进程，而是继续异步执行子进程。

二、API预览

destroy()

杀掉子进程。

exitValue()

返回子进程的出口值。

InputStream getErrorStream()

获得子进程的错误流。

InputStream getInputStream()

获得子进程的输入流。

OutputStream getOutputStream()

获得子进程的输出流。

waitFor()

导致当前线程等待，如果必要，一直要等到由该 Process 对象表示的进程已经终止。

三、如何创建Process对象，一般有一下两种方法：

1、每个 ProcessBuilder 实例管理一个进程属性集。start() 方法利用这些属性创建一个新的 Process 实例。start() 方法可以从同一实例重复调用，以利用相同的或相关的属性创建新的子进程。（ProcessBuilder这个是JDK5中新添加的final类，详细请参看“深入研究java.lang.ProcessBuilder类”一文。

2、Runtime.exec() 方法创建一个本机进程，并返回 Process 子类的一个实例。详细请参看“深入研究java.lang.Runtime类”一文。

四、实例

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStream;

import java.io.InputStreamReader;

/**

* 控制台处理工具箱

*

* @author leizhimin 2009-6-25 14:12:14

*/

public final class CmdToolkit {

private static Log log = LogFactory.getLog(CmdToolkit.class);

private CmdToolkit() {

}

/**

* 读取控制命令的输出结果

*

* @param cmd 命令

* @param isPrettify 返回的结果是否进行美化（换行），美化意味着换行，默认不进行美化,当此参数为null时也不美化，

* @return 控制命令的输出结果

* @throws IOException

*/

public static String readConsole(String cmd, Boolean isPrettify) throws IOException
{

StringBuffer cmdout = new StringBuffer();

log.info("执行命令：" + cmd);

Process process = Runtime.getRuntime().exec(cmd); //执行一个系统命令

InputStream fis = process.getInputStream();

BufferedReader br = new BufferedReader(new InputStreamReader(fis));

String line = null;

if (isPrettify == null || isPrettify) {

while ((line = br.readLine()) != null) {

cmdout.append(line);

}

} else {

while ((line = br.readLine()) != null) {

cmdout.append(line).append(System.getProperty("line.separator"));

}

}

log.info("执行系统命令后的结果为：\n" + cmdout.toString());

return cmdout.toString().trim();

}

}



这下行了吧，呵呵！

五、Process的的waitFor()造成的阻塞

我们在调用Process的waitFor()时经常会遇到明明Process已经结束了，但是waitFor()还是阻塞在那里，那是因为Process的inputStream缓存造成的，我们现在另外再起一个线程，来监控我们的Process，实时清空缓存就可以解决这个问题了

[java] view
plaincopy

class WatchThread extends Thread {

Process p;

boolean over;

ArrayList<String> stream;

public WatchThread(Process p) {

this.p = p;

over = false;

stream = new ArrayList<String>();

}

public void run() {

try {

if(p == null)return;

Scanner br = new Scanner(p.getInputStream());

while (true) {

if (p==null || over) break;

while(br.hasNextLine()){

String tempStream = br.nextLine();

if(tempStream.trim()==null||tempStream.trim().equals(""))continue;

stream.add(tempStream);

}

}

} catch(Exception e){e.printStackTrace();}

}



public void setOver(boolean over) {

this.over = over;

}

public ArrayList<String> getStream() {

return stream;

}

}



然后在waitFor之前插入

[java] view
plaincopy

WatchThread wt = new WatchThread(p2);

wt.start();



在waitFor之后插入

[java] view
plaincopy

ArrayList<String> commandStream = wt.getStream();

wt.setOver(true);



这样，即清空了inputStream，又不会造成需要的人无法获取inputStream的信息，waitFor()阻塞的问题也解决了