Java实现的并发任务处理实例

public void init() { super.init(); this.ioThreadPool = new ThreadPoolExecutor(50, 50, Long.MAX_VALUE, TimeUnit.SECONDS, new java.util.concurrent.LinkedTransferQueue<Runnable>(), new ThreadFactory() {  AtomicLong id = new AtomicLong();  @Override  public Thread newThread(final Runnable r) {   Thread t = new Thread(new Runnable() {    @Override    public void run() {     try {      r.run();     } catch (RuntimeException e) {      logger.error("执行IO异常", e);      throw e;     }    }   });   t.setDaemon(true);   t.setName("FootballService-IO-" + id.getAndIncrement());   return t;  } });}//从fdate到tdate， 结果： 日期 30个区的创建角色总和public Map<String, Long> countCreateRole(String fdate, String tdate, final String channel, Map<String, Object> gameConfig) throws Exception { // 只读数据不需要处理并发 final Map<String, String> param = new HashMap<String, String>(); param.put("fdate", fdate); param.put("tdate", tdate); param.put("channel", channel); final Map<String, Long> date_count = new HashMap<String, Long>(); final List<String> zones = (List<String>) gameConfig.get("areas"); Set<String> dateSet = JdbcTool.getDateRangeByDay(fdate, tdate, "yyyy-MM-dd"); List<Future<Void>> tasks = new ArrayList<>(zones.size()); for (String date : dateSet) {  final String _date = date;  tasks.add(publicThread.submit(new Callable<Void>() {   @Override   public Void call() {    final AtomicLong count = new AtomicLong();    List<Future<Void>> subTasks = new ArrayList<>(zones.size());    for (String _zone : zones) {     final String zone = _zone;     subTasks.add(ioThreadPool.submit(new Callable<Void>() {      @Override      public Void call() throws Exception {       JdbcTemplate _jdbcTemplate = dataSourceManager.getJdbcTemplate(zone);       String database = dataSourceManager.getDatabase(zone);       String _count = mget(CacheConstant.RZRoleCreateCount, zone + "#" + _date + "#" + channel + "#");       if (_count == null) {        StringBuilder sb = new StringBuilder();        sb.append("SELECT count(roleId) as count ");        sb.append("from " + database + "_log.role ");        sb.append("WHERE DATE(createTime)='" + _date + "' ");        if (param.get("channel") != null) {         sb.append(" AND channelId = '" + channel + "' ");        }        long queryForLong = _jdbcTemplate.queryForLong(sb.toString());        count.addAndGet(queryForLong);        mput(CacheConstant.RZRoleCreateCount, zone + "#" + _date + "#" + channel + "#", queryForLong + "");       } else {        count.addAndGet(Long.valueOf(_count));       }       return null;      }     }));    }    for (Future<Void> task : subTasks) {     try {      task.get();     } catch (Exception e) {      throw new RuntimeException(e);     }    }    synchronized (date_count) {     date_count.put(_date, count.get());    }    return null;   }  })); } for (Future<Void> task : tasks) {  task.get(); } return date_count;}@PreDestroypublic void destroy() { this.ioThreadPool.shutdownNow();}