设为首页 加入收藏

TOP

JAVA进程waitFor() 阻塞总结
2014-11-24 13:15:20 来源: 作者: 【 】 浏览:0
Tags:JAVA 进程 waitFor 阻塞 总结

最近在忙着一个模块的架构,先前采用的是单进程多线程的模式运行,因为可以很好管理。后来为了提高效率,必须把一群不断运行的线程放出去,好比分配房间样子,大伙再不用拘束在一个房间形成拥挤的状态了。


原来启动一个线程任务的时候是 把容器里存活对象开启它的状态,现在演变成生成一个线程,线程再去启动一个进程,从而把任务分配出去执行,但是,在一个线程启动一个进程后,因为要设计到数据通信,比如要等子进程完成后把子进程的结果返回回来。线程启动它后不可以被挂起。所有子进程需要在一个方法内存活。执行完毕后线程剩下的代码继续执行。后来发现waitFor()方法。挺不错,可以解决让子进程在线程的RUN方法就执行完毕,后来发现这个方法并不是想象的那么美好。它成功的停止了代码继续执行,同时它也阻塞了子进程的执行,因为子进程在测试的时候需要及时汇报信息和错误信息,如下对代码进行修改,初步上解决了waitFor()方法阻塞问题


新建一个线程类或者它为内部类


class StreamGobbler extends Thread
{
InputStream is;
String type;

StreamGobbler(InputStream is, String type)
{
this.is = is;
this.type = type;
}

public void run()
{
try
{
InputStreamReader isr = new InputStreamReader(is);
BufferedReader br = new BufferedReader(isr);
String line=null;
while ( (line = br.readLine()) != null)
System.out.println(type + ">" + line);
} catch (IOException ioe)
{
ioe.printStackTrace();
}
}
}


创建子进程的RUN方法


Process proc = Runtime.getRuntime().exec("java com.zjdw.course.Assign " + path);

new StreamGobbler(proc.getInputStream(),"INFO").start();

new StreamGobbler(proc.getErrorStream(),"ERROR").start();

int status = proc.waitFor();

if (status == 0)
System.out.println("执行完毕");
else
System.out.println("执行失败");


这样就可以解决阻塞问题了。


】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇在Linux下使用DNW给开发板下载 下一篇Linux内核实践之序列文件

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容: