本文實例講述了Java實現的并發(fā)任務處理方法。分享給大家供大家參考，具體如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
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("執(zhí)行IO異常", e); throw e; } } }); t.setDaemon(true); t.setName("FootballService-IO-" + id.getAndIncrement()); return t; } });}//從fdate到tdate， 結果： 日期 30個區(qū)的創(chuàng)建角色總和public Map<String, Long> countCreateRole(String fdate, String tdate, final String channel, Map<String, Object> gameConfig) throws Exception { // 只讀數據不需要處理并發(fā) 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();} |
希望本文所述對大家java程序設計有所幫助。
