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; }
@PreDestroy public void destroy() { this.ioThreadPool.shutdownNow(); }
相关推荐
第9节Spring对并发的支持:Spring的异步任务00:11:10分钟 | 第10节使用jdk8提供的lambda进行并行计算00:14:22分钟 | 第11节了解多线程所带来的安全风险00:13:16分钟 | 第12节从线程的优先级看饥饿问题00:18:42...
Java并发编程常见知识点源码集锦,涉及到对象锁,Executors多任务线程框架,线程池等示例,列出一些源码包中包括的内容: volatile关键字的非原子性、volatile关键字的使用、AtomicInteger原子性操作、线程安全小...
Spring对并发的支持:Spring的异步任务.mp4 使用jdk8提供的lambda进行并行计算.mp4 了解多线程所带来的安全风险.mp4 从线程的优先级看饥饿问题.mp4 从Java字节码的角度看线程安全性问题.mp4 synchronized保证线程...
龙果 java并发编程原理实战 第2节理解多线程与并发的之间的联系与区别 [免费观看] 00:11:59分钟 | 第3节解析多线程与多进程的联系以及上下文切换所导致资源浪费问题 [免费观看] 00:13:03分钟 | 第4节学习并发的四...
Java并发编程是一种高效的编程技术,通过多线程实现将计算过程中不必要的等待时间用于处理其它工作,从而提高了计算机的利用效率。但同时,多线程编程也带来了不少挑战,诸如线程安全、性能问题等,需要程序员采取...
java并发编程原理实战 第2节理解多线程与并发的之间的联系与区别 [免费观看] 00:11:59分钟 | 第3节解析多线程与多进程的联系以及上下文切换所导致资源浪费问题 [免费观看] 00:13:03分钟 | 第4节学习并发的四个...
第9节Spring对并发的支持:Spring的异步任务00:11:10分钟 | 第10节使用jdk8提供的lambda进行并行计算00:14:22分钟 | 第11节了解多线程所带来的安全风险00:13:16分钟 | 第12节从线程的优先级看饥饿问题00:18:42...
最近笔者正好有所涉及,鉴于此,结合开发中的案例说明一下几种定时任务的 退出 。 需求说明 :定时更新正在生成的文件大小和状态【进行中、失败、完成】,如果文件生成完成,则退出【CoderBaby】 调度可以用 ...
Java多线程实现数据切割批量执行,实现限流操作。 java线程池Executors实现数据批量操作。 ...案例适合: 1.批量处理大数据。 2.数据批量导出。 3任务数据异步执行。 4.多线程请求第三方接口限流。
12.5.3 使用JDK5.0后提供的并发集合类324 12.6 用Timer类调度任务325 12.7 本章练习326 第13章 13.1 java.io.File类328 13.1.1 文件和目录是什么?328 13.1.2 Java对文件和目录的操作328 13.2 JavaIO原理332 13.3 流...
高并发编程第三阶段18讲 CountDownLatch经典案例讲解如何给离散平行任务增加逻辑层次关系-下_.mp4 高并发编程第三阶段19讲 CyclicBarrier工具的使用场景介绍_.mp4 高并发编程第三阶段20讲 CyclicBarrier vs ...
文件如果特别小,而自己网络又非常好的情况下,不建议使用线程池进行下载,因为线程任务的创建也会浪费一些时间和性能!因为写这个程序是为了更快的下载一些4K壁纸,所以传入的url只能是直链,当然 可以根据自己的...
Java波浪文字,一个利用Java处理字符的实例,可以设置运动方向参数,显示文本的字符数组,高速文本颜色,显示字体的 FontMetrics对象,得到Graphics实例,得到Image实例,填充颜色数组数据,初始化颜色数组。...
Java波浪文字,一个利用Java处理字符的实例,可以设置运动方向参数,显示文本的字符数组,高速文本颜色,显示字体的 FontMetrics对象,得到Graphics实例,得到Image实例,填充颜色数组数据,初始化颜色数组。...
" "及编程技能 " " " "3 "数组和字符串 "掌握数组、字符串运 "讲授、单元实验 "8 " " " "用及编程技能 " " " "4 "异常处理 "了解异常机制,掌握 "讲授、单元实验 "8 " " " "基本异常处理方式 " " " "5 "多线程并发 ...
非常简单和轻量级的 Java util 类,用于协助创建并发任务和循环并行化。 您可以使用这个库来并行处理集合,只需使用很少的行。 如果您需要更强大的功能,建议您检查一下功能Java项目,该项目提供了高阶并发抽象 。 ...
例如,基于进程的多任务处理可以在运行Java编译器的同时使用文本编辑器或浏览网站。在基于进程的多任务处理中,程序是调度程序能够调度的最小代码单元。 第6页 Java程序设计案例教程-第8章-多线程编程全文共36页,...
高并发编程第三阶段18讲 CountDownLatch经典案例讲解如何给离散平行任务增加逻辑层次关系-下_.mp4 高并发编程第三阶段19讲 CyclicBarrier工具的使用场景介绍_.mp4 高并发编程第三阶段20讲 CyclicBarrier vs ...