Junit单元测试子线程不执行

养成写单元测试是个好习惯，这样能在前期把大部分边界问题测试清楚，减少代码的bug，提升项目上线的信心，但是我们在用junit进行单元测试的时候有时候会遇到很多坑，不断总结不但可以提高些代码的水平，还能避免下次再犯同类错误，最近就遇到一个用单元测试进行多线程测试的坑。

直接上代码：

public class RuleFilterThread{

public RuleFilterThread(Map<String, String> dataMap,  Rule rule, RuleFilter ruleFilter,Class<?> filterClass,Class ruleClass) {
        this.rule = rule;
        this.ruleFilter = ruleFilter;
        this.dataMap = dataMap;
        this.filterClass =filterClass;
        this.ruleClass=ruleClass;
    }

    @Override
        try {
            //compile class
            //TODO: optimize to cache compiled class .
//            Class<?> clazz = ClassLoaderUtil.loadClass(convertClassNameWithId(filterScript, ruleFilter.getId()));
            Object result = ClassLoaderUtil.execute(filterClass, FILTER_METHOD, dataMap);
            logger.info("execute rule filter result {}",result);
            if (!(result instanceof Boolean)) {
                logger.error("rule filter {} of rule {} filter method return value is not correct ,should return boolean value", ruleFilter.getId(), rule.getId());
                return;
            }

            if ((boolean) result) {
                logger.info("start handle sample rate ...");
                //采样率，qps等处理
                if (handleSapmleRate(rule.getSamplingRate())) {
                    logger.info("start to call rule script:{}",rule.getRuleScript());
                    // 调用规则配置
//                    Class<?> clazz1 = ClassLoaderUtil.loadClass(convertClassNameWithId(ruleScript, rule.getId()));
                    Object callRuleRes =  ClassLoaderUtil.execute(ruleClass, PROCESS_METHOD, dataMap);
                    System.out.println("result: "+callRuleRes);
                    // 验证结果保存
                    saveCheckResult((Map)callRuleRes, rule, dataMap, null);
                }
            }
        } catch (Exception e) {
            logger.error("Error occured  ", e);
            saveCheckResult(null, rule, dataMap, e);
        }

    }

    public static String convertClassNameWithId(String code, String className,int id) {
        return StringUtils.replace(code, className, className + id);
    }
}

写了一个线程来对数据进行规则过滤，其中用到了反射工具进行类执行，然后写了个单元测试：

  @Test
    public void testRuleThread()throws  Exception{
        Map map=new HashMap<String,String>();
        map.put("__biz_table_id","2");
        map.put("id","111");
        Rule rule=ruleRepository.findByBizTableId(Integer.parseInt((String)map.get("__biz_table_id")));
        RuleFilter ruleFilter=ruleFilterRepository.findByRuleId(rule.getId());

        Class<?> filterClass = ClassLoaderUtil.loadClass(RuleFilterThread.convertClassNameWithId(ruleFilter.getFilterScript(),"RuleFilter", ruleFilter.getId()));

        Class<?> ruleClass = ClassLoaderUtil.loadClass(RuleFilterThread.convertClassNameWithId(rule.getRuleScript(),"ProcessImp", rule.getId()));

        RuleFilterThread ruleFilterThread=new RuleFilterThread(map,rule,ruleFilter,filterClass,ruleClass);
       Thread t1= new Thread(ruleFilterThread);
       t1.start();
   //    t1.join();

    }

 这里其实没有就是先动态编译类，然后执行线程，但是在调试的时候，程序会半途终止，但是没有任何异常信息，开始以为是代码问题，但是尝试通过controller调用就没有任何问题，经过度娘才发现是junit不支持线程调用，当单元测试结束后，程序就会自己终止。

解决办法：

1，现场加上join方法，如上加入t1.join()即可

2，通过main方法测试就不会有此问题。