多线程之线程池的应用

publicclassBegincode implementsRunnable {    
    publicvoidrun() {  
        System.out.println(“Begincode--runable”); 
    } 
}

publicclassBegincode implementscallable{   
    publicvoidcall() {  
        System.out.println(“Begincode--callable”); 
    } 
}

execute这种方式提交没有返回值，也就不能判断是否执行成功。

submit这种方式它会返回一个Future对象，通过future的get方法来获取返回值，get方法会阻塞住直到任务完成。

四、关闭线程池

当我们不需要使用线程池的时候，我们需要对其进行关闭…有两种方法可以关闭掉线程池…

shutdown()

shutdown并不是直接关闭线程池，而是不再接受新的任务…如果线程池内有任务，那么把这些任务执行完毕后，关闭线程池….

shutdownNow()

这个方法表示不再接受新的任务，并把任务队列中的任务直接移出掉，如果有正在执行的，尝试进行停止…

案例分享

需求：从数据库中获取url，并利用httpclient循环访问url地址，并对返回结果进行操作

分析：由于是循环的对多个url进行访问并获取数据，为了执行的效率，考虑使用多线程，url数量未知如果每个任务都创建一个线程将消耗大量的系统资源，最后决定使用线程池。

给大家贴上代码

publicclass GetMonitorDataService {
 
    privateLogger logger = LoggerFactory.getLogger(GetMonitorDataService.class);
    @Resource
    privateMonitorProjectUrlMapper groupUrlMapper;
    @Resource
    privateMonitorDetailBatchInsertMapper monitorDetailBatchInsertMapper;
    publicvoid sendData(){
        //调用dao查询所有url
        MonitorProjectUrlExample example=newMonitorProjectUrlExample();
        List<MonitorProjectUrl> list=groupUrlMapper.selectByExample(example);
        logger.info("此次查询数据库中监控url个数为"+list.size());
 
        //获取系统处理器个数，作为线程池数量
        intnThreads=Runtime.getRuntime().availableProcessors();
 
        //定义一个装载多线程返回值的集合
        List<MonitorDetail> result= Collections.synchronizedList(newArrayList<MonitorDetail>());
        //创建线程池，这里定义了一个创建线程池的工具类，避免了创建多个线程池
        ExecutorService executorService = ThreadPoolFactoryUtil.getExecutorService(nThreads);
        //遍历数据库取出的url
        if(list!=null&&list.size()>0) {
            for(MonitorProjectUrl monitorProjectUrl : list) {
                String url = monitorProjectUrl.getMonitorUrl();
                //创建任务
                ThreadTask threadTask = newThreadTask(url, result);
                //执行任务
                executorService.execute(threadTask);
            }
            //对数据进行操作
            saveData(result);
        }
    }

publicclass ThreadTask implementsRunnable{
    //这里实现runnable接口
    privateString url;
    privateList<MonitorDetail> list;
    publicThreadTask(String url,List<MonitorDetail> list){
        this.url=url;
        this.list=list;
    }
    //把获取的数据进行处理
    @Override
    publicvoid run() {
        MonitorDetail detail = HttpClientUtil.send(url, MonitorDetail.class);
        list.add(detail);
    }
 
}