package com.allywll.core.exec.base;
import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.nio.charset.Charset;
import java.util.LinkedList;
import java.util.List;
import java.util.concurrent.TimeoutException;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import com.allywll.core.util.PeriodicalTask;
import com.gzit.core.util.ArrayUtil;
/**
* 对一个外部进程执行过程的抽象
*
* @author gzit team
*
*/
public class ProcessorExecutor implements CmdExecutor {
private static Logger logger = Logger.getLogger("PROCESSOR");
// 进程的执行路径
protected String workingDirectory;
// 进程输出的字符编码
// 默认使用平台的字符编码
private String outputEncoding = Charset.defaultCharset().name();
// 进程的执行命令
protected String cmd;
// 进程的执行参数
protected String[] args;
// 进程执行的超时时间 ：单位为毫秒，-1不考虑超时机制，有超时的话将外部进程destroy掉
protected long timeout = -1;
protected long beginTime;// 进程执行的开始时间
protected long endTime;// 进程执行的结束时间
protected Process process; // 当前执行的进程
protected boolean blocking;// 当前执行的进程是否正处在阻塞之中
protected boolean flagTimeout;// 是否发生超时异常
/**
*
* 进程执行过程的监控(超时以及其它的状态检测)
*
*/
private static class ExecutorMonitor extends PeriodicalTask {
private Logger elogger = Logger.getLogger("PROCESSOR");
private List<ProcessorExecutor> executors = new LinkedList<ProcessorExecutor>();
public ExecutorMonitor(int period) {
super(period);
}
public void reg(ProcessorExecutor exec) {
this.executors.add(exec);
}
public synchronized void deReg(ProcessorExecutor exec) {
if (exec != null) {
this.executors.remove(exec);
}
}
@Override
protected void doWork() throws Exception
