Java之线程开发

淡淡的烟草味﹌ 2022-05-12 11:20 151阅读 0赞

**继承Thread类：**  
线程是指进程中的一个执行流程，一个进程中可以运行多个线程。  
例如：java.exe进程中可以运行很多线程。线程总是属于某个进程，进程中的多个线程共享进程的内存。

线程启动时会去调用 run 方法，所以只要重写 Thread 类的 run 方法就可以定义出我们的线程类：  
业务需求：  
将页面信息保存到两表中(城市表和城市临时表)，同时将信息Id及创建日期(yyyy/MM/dd HH:mm:ss)保存到日志表。(这里保存日志用到的线程)

1.定义接口方法：

//将页面信息保存到两表中(城市表和城市临时表)
        public void uploadAll(Map<String, String> map);

2.编写业务逻辑：

@Override
        public void uploadAll(Map<String, String> map) {
            Map mapCity = new HashedMap();
            mapCity.put("cityCode",map.get("cityCode"));
            mapCity.put("cityName",map.get("cityName"));
            mapCity.put("cityType",map.get("cityType"));
            //插入城市表
            sysCityDao.upload(mapCity);
            Map mapCityTemp = new HashedMap();
            mapCityTemp.put("cityCode",map.get("cityCode"));
            mapCityTemp.put("cityName",map.get("cityName"));
            mapCityTemp.put("parentCode",map.get("parentCode"));
            //插入城市临时表
            sysCityDao.uploadtemp(mapCityTemp);
            //线程池操作
            SelThread selThread = new SelThread(selCityDao,sysCityDao,map);
            threadPoolFactory.taskExecutor().execute(selThread);
        }

3.定义线程池：

@Service
    @Scope("singleton")
    public class ThreadPoolFactory { 
        public Log log = LogFactory.getLog(getClass());
        private ThreadPoolTaskExecutor poolTaskExecutor;
        @PostConstruct
        public void init() {
            log.info("-------初始化线程池------");
            taskExecutor();
        }
    
        public ThreadPoolTaskExecutor taskExecutor() {
            if(poolTaskExecutor==null){
                poolTaskExecutor = new ThreadPoolTaskExecutor();
                //线程池维护线程的最少数量
                poolTaskExecutor.setCorePoolSize(10);
                //线程池维护线程的最大数量
                poolTaskExecutor.setMaxPoolSize(100);
                //线程池所使用的缓冲队列
                poolTaskExecutor.setQueueCapacity(5000);
                //等待线程执行完成
                poolTaskExecutor.setWaitForTasksToCompleteOnShutdown(true);
                //线程池维护线程所允许的空闲时间
                poolTaskExecutor.setKeepAliveSeconds(30000);
                //线程池对拒绝任务的处理
                poolTaskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
                poolTaskExecutor.initialize();
            }
            return poolTaskExecutor;
    
        }
    }

4.定义新类，继承Thread类：  
**注意：**  
**查询当前日期用的SimpleDateFormat ，是String类型，最终需要获得的是Date类型，用parse转换。**例如：

Date now = new Date();
                SimpleDateFormat df = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
                String newDate = df.format(now);
                Date date = df.parse(newDate);

新类编写代码：

public class SelThread extends Thread{ 
        public Log logger = LogFactory.getLog(getClass());
    
        //私有业务层中的参数。
        private SysCityDao sysCityDao;
        private SelCityDao selCityDao;
        private Map<String,String> map;
    
        public SelThread(SelCityDao selCityDao,SysCityDao sysCityDao,Map<String, String> map) {
            this.sysCityDao = sysCityDao;
            this.selCityDao=selCityDao;
            this.map=map;
        }
        @Override
        public void run() {
            try{
                SelCity selCity=new SelCity();
                Date now = new Date();
                SimpleDateFormat df = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");//可以方便地修改日期格式
                String newDate = df.format(now);
                Date date = df.parse(newDate);
                selCity.setTime(date);
                //获取map中的cityCode。
                String queryCode=map.get("cityCode");
                selCity.setId(queryCode);//查询Code
                logger.info("城市记录信息"+selCity);
                selCityDao.insert(selCity);
            }catch (Exception e) {
                logger.error("城市信息记录日志，异常" + e.getMessage(), e);
            }
        }
    }

输出结果日志：  
![这里写图片描述][70]

[70]: /images/20220512/d43ad2c1a3884371bfad90a125c7c1b1.png