最近在忙着一个模块的架构，先前采用的是单进程多线程的模式运行，因为可以很好管理。后来为了提高效率，必须把一群不断运行的线程放出去，好比分配房间样子，大伙再不用拘束在一个房间形成拥挤的状态了。
原来启动一个线程任务的时候是 把容器里存活对象开启它的状态，现在演变成生成一个线程，线程再去启动一个进程，从而把任务分配出去执行，但是，在一个线程启动一个进程后，因为要设计到数据通信，比如要等子进程完成后把子进程的结果返回回来。线程启动它后不可以被挂起。所有子进程需要在一个方法内存活。执行完毕后线程剩下的代码继续执行。后来发现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("执行失败");
这样就可以解决阻塞问题了。
