zoukankan      html  css  js  c++  java
  • java中使用连接池的写法

                s=conn.createStatement();
                String sql="SELECT COUNT(*) count from t_wlk where (status=19 or status=0) and department in ('dx','dxft');";
                ResultSet rs=s.executeQuery(sql);
                rs.next();
                count=Integer.parseInt(rs.getString("count"));            
                System.out.println(sdf.format(time)+"  开始更新卡状态……");
                System.out.println("本次应处理条数:"+count);
                        
                if(count<200){
                    thread_num = 1;
                    action=count+1;
                }else if(count<1000){
                    thread_num = 3;
                    action=(count/3)+1;
                }else if(count<3000){
                    thread_num = 5;
                    action=(count/5)+1;        
                }else if(count<10000){
                    thread_num = 10;
                    action=(count/10)+1;        
                }else {
                    thread_num = 20;
                    action=(count/20)+1;    
                }
                
                executor = Executors.newFixedThreadPool(thread_num);
                
                for(int i=0;i<thread_num;i++){
                    final int begin_num = i*action;
                    Runnable runn = new Runnable() {                
                        @Override
                        public void run() {
                            action(begin_num);                        
                        }
                    };
                    System.out.print("t"+i+"启动 ,");
                    executor.execute(runn);
                }
                System.out.println();
                
            } catch (Exception e) {
                e.printStackTrace();
            }finally{            
                CardDao.close(conn);
                CardDao.closeStment(s);            
                executor.shutdown();
                while(true){  
                    if(executor.isTerminated()){  
                        time=new Date();
                        System.out.println("本次已经处理完了的条数:"+number);
                        System.out.println("其中月套餐的条数是:"+costsnum);
                        System.out.println("其中累计卡的条数是:"+addnum);
                        System.out.println(sdf.format(time));
                        break;  
                    }
                    try {
                        Thread.sleep(2000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }                   
                }     
            }

  • 相关阅读:
    解释机器学习模型的一些方法(一)——数据可视化
    机器学习模型解释工具-Lime
    Hive SQL 语法学习与实践
    LeetCode 198. 打家劫舍(House Robber)LeetCode 213. 打家劫舍 II(House Robber II)
    LeetCode 148. 排序链表(Sort List)
    LeetCode 18. 四数之和(4Sum)
    LeetCode 12. 整数转罗马数字(Integer to Roman)
    LeetCode 31. 下一个排列(Next Permutation)
    LeetCode 168. Excel表列名称(Excel Sheet Column Title)
    论FPGA建模,与面向对象编程的相似性
  • 原文地址:https://www.cnblogs.com/zpbk/p/8550276.html
Copyright © 2011-2022 走看看