标签：定时器 getInstance timer instance 线程 dataSource DruidDataSource DruidDataSourceFact

• 定时发送消息主类(Sendmail):
  
• 从数据库表中读取符合条件的信息使用线程池进行发送

public class Mytask  extends TimerTask {
    @Override
    public void run() {
        //使用mysql
        List<String> curtask = new ArrayList<>();
        DataSource DruidDataSource = DruidDataSourceFactory.getInstance();
        ExecutorService pool = Executors.newCachedThreadPool();
        try(Connection Connection = DruidDataSource.getConnection()) {
            Statement statement = Connection.createStatement();
            String sql = "select name from test where time between '2019-08-30' and '2019-08-31';";
            ResultSet r = statement.executeQuery(sql);
            while (r.next()){
                curtask.add(r.getString("name"));
            }
            for(int i=0;i<curtask.size();i++){
                pool.submit(new SendMailProcesser(curtask.get(i)));
                }
            pool.shutdown();
            while (!pool.isTerminated()){
                //等待所有线程结束
            }
            System.out.println("main结束时间:"+ now());
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    String now(){
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        return format.format(new Date());
    }
}

• 发送消息内容:
  
• 使用单例模式+volatile关键字+双重检查的方式构建数据池:

public class DruidDataSourceFactory {
    private static volatile DruidDataSource instance = null;
    private DruidDataSourceFactory() {};
    public static DataSource getInstance() {
        if (instance == null) {
            synchronized (DruidDataSourceFactory.class) {
    if (instance == null) {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setUsername(Constants.getInstance().getProperties().getProperty("username"));
        dataSource.setPassword(Constants.getInstance().getProperties().getProperty("password"));
        dataSource.setUrl(Constants.getInstance().getProperties().getProperty("url"));
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        try {
            dataSource.init();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        instance = dataSource;
    }
            }
        }
    return instance;
}}

标签：定时器,getInstance,timer,instance,线程,dataSource,DruidDataSource,DruidDataSourceFact
来源： https://blog.csdn.net/leifei2012/article/details/100561294

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。