java多线程

1.创建多线程的方法

/**@param queryDate 日期
     * @param sId  电站sId
     * @param busiCode 汇流箱业务编号
     * @param pvkpilow 低效门限
     * @return List<Object []> 
     */
	@Override
	public List<Object[]> queryConcentratePVRuntimeStatus(
			String queryDate, String sId,String[] busiCode, Object pvkpiLow) {
	    List<Object[]> retList = new ArrayList<Object[]>();
	    initReportService();
	    //创建两个容量的线程池，一个查询组串有效功率和平均值，一个查询每个组串有效功率和
	    ExecutorService es = Executors.newFixedThreadPool(2);
        List<Future<List<Object[]>>> futureList = new ArrayList<Future<List<Object[]>>>();
        //查询组串有效功率和平均值
        futureList.add(es.submit(new pvkpiConcentrateAvgThread(this.reportService, queryDate, sId,busiCode)));
        //查询每个组串有效功率和
        futureList.add(es.submit(new pvkpiConcentrateValueThread(this.reportService, queryDate, sId,busiCode)));
        try {
        	
            //有效功率和平均值
            List<Object[]> avgList= futureList.get(0).get();
            //组串有效功率和
            List<Object[]> valueList= futureList.get(1).get();
            Map<String, Double> avgMap = new HashMap<String, Double>();
            for(Object[] o : avgList){
                avgMap.put(String.valueOf(o[1]), Double.valueOf(String.valueOf(o[2])));
            }

            Object[] retObject = null;
            for(Object[] o : valueList){
                retObject = new Object[25];
            	retObject[0] = o[0];//电站ID
            	retObject[2] = o[22];//汇流箱名称
            	retObject[3] = o[1];//业务编号
                boolean isShow = false;
                
                double pvAvg = avgMap.containsKey(String.valueOf(o[1]))?avgMap.get(String.valueOf(o[1])):0;
                double doublepvkpiLow = Double.parseDouble(pvkpiLow.toString());
                for(int i = 2; i <22; i++){
                    String pvValue = String.valueOf(o[i]);//组串状态
                    retObject[i+2] = "OK";
                    //组串1状态
                    if("ERROR".equals(o[i])){
                        retObject[i+2] = "ERROR";
                        isShow = true;
                    } else if ("UNASSEMBLED".equals(o[i])){
                        retObject[i+2] = "UNASSEMBLED";
                    } else if(Double.valueOf(pvValue) < pvAvg){
                        //计算组串是否低效
                        if(1-(pvAvg - Double.valueOf(pvValue))/pvAvg < doublepvkpiLow){
                            retObject[i+2] = "LOW";
                            isShow = true;
                        }
                    }
                }
                if(isShow){
                	retObject[24] = queryDate;//查询时间
                    retList.add(retObject);
                }
            }
            
        } catch (Exception e) {
            Log.error("多线程查询集中式组串运行状态异常 ： ", e);
        }
        es.shutdown();
        return retList;
	}

线程方法1：
/**
 * 查询汇流箱每个组串有效功率和平均值
 * Create Date: 2015-7-13<br>
 * Create Author: xWX244078<br>
 * Description :
 */
public class pvkpiConcentrateAvgThread implements Callable<List<Object[]>> {
    private IRmiOfReportDataService dataService;
    
    private String queryDate;
    private String sId;
    private String[] busiCode;

    public pvkpiConcentrateAvgThread(IRmiOfReportDataService dataService,
        String queryDate, String sId,String[] busiCode) {
      
        this.queryDate = queryDate;
        this.sId = sId;
        this.busiCode = busiCode;
        this.dataService = dataService;
    }

    @Override
    public List<Object[]> call() throws Exception {
        // TODO Auto-generated method stub
        if(null != dataService){
            return dataService.queryConcentrateAvg(queryDate, sId, busiCode);
        }
        return null;
    }

}

线程方法2：
/**
 * 查询每个汇流箱组串有效功率和
 * Create Date: 2015-7-13<br>
 * Create Author: xWX244078<br>
 * Description :
 */
public class pvkpiConcentrateValueThread implements Callable<List<Object[]>> {
    private IRmiOfReportDataService dataService;
   
    private String queryDate;
    private String sId;
    private String[] busiCode;

    public pvkpiConcentrateValueThread(IRmiOfReportDataService dataService,
        String queryDate, String sId, String[] busiCode) {
       
        this.queryDate = queryDate;
        this.sId = sId;
        this.busiCode = busiCode;
        this.dataService = dataService;
    }

    @Override
    public List<Object[]> call() throws Exception {
        // TODO Auto-generated method stub
        if(null != dataService){
            return dataService.queryConcentrateValue(queryDate, sId, busiCode);
        }
        return null;
    }

}