ConcurrentLatch

/**添加这个类运行的任务名，注意这个名字在一次线程池运行中不可重复*/
/**也可以不配置注解，写一个名为TASKNAME的字符串成员变量也可行*/
@LatchTaskName("rule")
/**需实现LatchThread接口，并将业务代码写入handle方法，否则会抛出异常*/
public class RuleLatch implements  LatchThread {
    RuleDto dto = null;
    /**通过构造方法传递入参*/
    public RuleLatch(RuleDto args){
        dto = args;
    }
    /**你的业务处理*/
    public RuleDto handle() {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        dto.setMmmm(dto.getMmmm()+ 9999);
        return dto;
    }
}
/**添加这个类运行的任务名，注意这个名字在一次线程池运行中不可重复*/
/**也可以不配置注解，写一个名为TASKNAME的字符串成员变量也可行*/
/**这个配置的注解值必须和对应的LatchThread一致，否则会抛出异常*/
@LatchTaskName("rule")
public class RuleDto {
……
}

/**创建一个ConcurrentLatch执行器*/
ConcurrentLatchExcutor excutor = new ConcurrentLatchExcutor();
/**组织需要并发的业(任)务(务)类对象*/
LatchThread platformLatchThread = new PlatformLatch();//业务类A
RuleDto ruleDto = new RuleDto();
ruleDto.setRuleID("zxp123");
ruleDto.setMmmm(0.00001);
LatchThread ruleLatchThread = new RuleLatch(ruleDto);//业务类B
/**将任务推入ConcurrentLatch执行器*/
excutor.put(platformLatchThread);
excutor.put(ruleLatchThread);
/**通知ConcurrentLatch执行器开始执行所有推入的任务*/
/**这里会阻塞，直到所有任务都执行完毕*/
Map<String, Object> map = excutor.excute();
/**获取返回值*/
/**这里的key就是上面在注解(LatchTaskName)或者TASKNAME配置的值，能轻松的获取所有的返回对象*/
for (String key : map.keySet()) {
    Object out = map.get(key);
}

/**单个线程池线程最大容量*/
CURRENT_MAX_POOL_COUNT = 4;
/**线程池最大数量*/
int MAX_EXCUTOR_COUNT = 3;