手机版
你好,游客 登录 注册
背景:
阅读新闻

JAVA进程waitFor() 阻塞总结

[日期:2011-11-18] 来源:Linux社区  作者:Tiwen818 [字体: ]

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

原来启动一个线程任务的时候是 把容器里存活对象开启它的状态,现在演变成生成一个线程,线程再去启动一个进程,从而把任务分配出去执行,但是,在一个线程启动一个进程后,因为要设计到数据通信,比如要等子进程完成后把子进程的结果返回回来。线程启动它后不可以被挂起。所有子进程需要在一个方法内存活。执行完毕后线程剩下的代码继续执行。后来发现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
相关资讯       JAVA基础教程 
本文评论   查看全部评论 (1)
表情: 表情 姓名: 字数

       

评论声明
  • 尊重网上道德,遵守中华人民共和国的各项有关法律法规
  • 承担一切因您的行为而直接或间接导致的民事或刑事法律责任
  • 本站管理人员有权保留或删除其管辖留言中的任意内容
  • 本站有权在网站内转载或引用您的评论
  • 参与本评论即表明您已经阅读并接受上述条款
第 1 楼
* 匿名 发表于 2017/1/16 15:37:58
不懂呢