文档章节

java-CompletionService使用小记

fangsw
 fangsw
发布于 2017/07/20 11:23
字数 572
阅读 41
收藏 0

由于项目性能需求,之前单线程阻塞查询云端数据效率太慢,需要改进。百度了下CompletionService还是蛮符合需求的。

package com.demo.thread.executor;

import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.CompletionService;
import java.util.concurrent.ExecutorCompletionService;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ExecuteMain {
	
	//线程池大小
	private static final int THREAD_POOL_SIZE = Runtime.getRuntime().availableProcessors();
	//最大线程
	private static final int THREAD_MAXIMUM_POOL_SIZE = Runtime.getRuntime().availableProcessors() * 2 + 1;

	public static void main(String[] args) {
		try {
			ExecuteMain main = new ExecuteMain();
			main.execService();
		} catch(InterruptedException e) {
			System.out.println("进入异常");
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	//执行线程
	public void execService() throws Exception {
		ExecutorService executorService = new ThreadPoolExecutor(THREAD_POOL_SIZE, THREAD_MAXIMUM_POOL_SIZE, 0L, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(THREAD_MAXIMUM_POOL_SIZE ), new RejectedExecutionHandler() {
			
			@Override
			public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
				try {
                    //改为阻塞方法
					executor.getQueue().put(r);
				} catch (Exception e) {
					
				}
			}
		});
		CompletionService<Integer> completionService  = new ExecutorCompletionService<Integer>(executorService);
		try {
			List<Integer> accountIdList = genAccountId();
			for (Integer accountId : accountIdList) {
                final finalAccountId = accountId;
				completionService.submit(buildTask(accountId));
			}
			
			int resultNum = 0;
			for (int i = 0; i < accountIdList.size(); i++) {
				resultNum = completionService.take().get();
				 System.out.println("第" +(i + 1)+"个执行结果" + resultNum);  
			}
			 System.out.println("全部任务执行完成");
		} catch(InterruptedException e) {
			e.printStackTrace();
		} catch (Exception e) {
			executorService.shutdownNow(); 
			throw e;
		} finally {
			executorService.shutdownNow(); 
		}
	}
	
	//生成任务
	public Callable<Integer> buildTask(final int accountId) throws InterruptedException {
		final Random rand = new Random(); 
		Callable<Integer> task = new Callable<Integer>() {
			@Override
			public Integer call() throws Exception {
				System.out.println("执行任务" + Thread.currentThread().getName());
				int time = rand.nextInt(100)*100;
				Thread.currentThread().sleep(time);
				if(accountId > 10) {
					throw new InterruptedException("throws Exception");
				}
				return accountId;
			}
		};
		return task;
	}
	
	//生成账号
	public List<Integer> genAccountId() {
		List<Integer> accountIdList = new ArrayList<Integer>();
		accountIdList.add(3);
		accountIdList.add(1);
		accountIdList.add(2);
		accountIdList.add(4);
		accountIdList.add(5);
		accountIdList.add(6);
		accountIdList.add(7);
		accountIdList.add(8);
		accountIdList.add(9);
		accountIdList.add(10);
		accountIdList.add(11);
		accountIdList.add(12);
		accountIdList.add(13);
		accountIdList.add(14);
		accountIdList.add(15);
		accountIdList.add(16);
		accountIdList.add(17);
		accountIdList.add(18);
		return accountIdList;
	}
}

demo如上,结果如下

 

关于CompletionService的原理,可以先百度了解下。这里写下注意事项

1.completionService.take().get(); 这里是没有顺序的,如果程序执行时对有顺序有要求,需要谨慎

2.当callable中出现异常,外层方法必须调用completionService.take().get();这句才能捕获队列的受检查异常。

3.如果你callable中的方法A,又调用了另外一个方法B,而且B方法存在回调行为(比如说查询出结果后还会做其他处理),这时不要使用shutdownNow()进行关闭。否则可能会出现,云端任务执行状态和本地状态不匹配的情况,因为当出现异常时,你调用shutdownNow()后线程结束了,回调时本地状态未更新。

4.线程任务中的参数一定要用final修饰,不然可能会出现入参和结果不匹配情况

© 著作权归作者所有

fangsw
粉丝 2
博文 19
码字总数 5274
作品 0
杭州
私信 提问
Java 并发:Executors 和线程池

本文译自:Java Concurrency – Part 7 : Executors and thread pools 让我们开始来从入门了解一下 Java 的并发编程。 本文主要介绍如何开始创建线程以及管理线程池,在 Java 语言中,一个最...

红薯
2010/09/15
34K
18
Java 并发 – 第七部分:Executors 与线程池

现在让我们开始 Java 并发系列的新篇章。这壹次我们会学习如何干净的启动壹個新线程,以及如何在线程池中管理它。在 Java 中,假设你有壹個像下面这样的 Runnable 线程: Runnable runnable ...

苗哥
2013/10/07
2.8K
6
热修复与插件化基础——Java与Android虚拟机

一、Java虚拟机(JVM) 1、JVM整体结构 使用javac将java文件编译成class文件。 类加载器(ClassLoader)将class字节码加载进JVM对应的内存中。 JVM将内存分配给方法区、堆区、栈区、本地方式...

CSDN_LQR
2018/05/13
0
0
Java 并发之 Future 接口

简介 Future 是 Java 5 JUC 包中的一个接口,主要提供了三类功能: 任务结果的获取 这个功能由 get 方法提供,它有两种形式的重载。get 方法本身使用起来很简单,需要注意的是它所抛出的异常...

编走编想
2013/11/13
1K
3
设计模式(思想)还是基础?

最近在网上看到一个提问:j2se的基础重要,还是设计模式、设计思想重要? 近似永远正确的回答是:两者都重要。 解道banq的观点: 我不想说太多,我可以告诉你我目前的情况: 我已经几年没有去...

穿越星辰
2010/05/13
57
0

没有更多内容

加载失败,请刷新页面

加载更多

64.监控平台介绍 安装zabbix 忘记admin密码

19.1 Linux监控平台介绍 19.2 zabbix监控介绍 19.3/19.4/19.6 安装zabbix 19.5 忘记Admin密码如何做 19.1 Linux监控平台介绍: 常见开源监控软件 ~1.cacti、nagios、zabbix、smokeping、ope...

oschina130111
今天
13
0
当餐饮遇上大数据,嗯真香!

之前去开了一场会,主题是「餐饮领袖新零售峰会」。认真听完了餐饮前辈和新秀们的分享,觉得获益匪浅,把脑子里的核心纪要整理了一下,今天和大家做一个简单的分享,欢迎感兴趣的小伙伴一起交...

数澜科技
今天
7
0
DNS-over-HTTPS 的下一代是 DNS ON BLOCKCHAIN

本文作者:PETER LAI ,是 Diode 的区块链工程师。在进入软件开发领域之前,他主要是在做工商管理相关工作。Peter Lai 也是一位活跃的开源贡献者。目前,他正在与 Diode 团队一起开发基于区块...

红薯
今天
12
0
CC攻击带来的危害我们该如何防御?

随着网络的发展带给我们很多的便利,但是同时也带给我们一些网站安全问题,网络攻击就是常见的网站安全问题。其中作为站长最常见的就是CC攻击,CC攻击是网络攻击方式的一种,是一种比较常见的...

云漫网络Ruan
今天
12
0
实验分析性专业硕士提纲撰写要点

为什么您需要研究论文的提纲? 首先当您进行研究时,您需要聚集许多信息和想法,研究论文提纲可以较好地组织你的想法, 了解您研究资料的流畅度和程度。确保你写作时不会错过任何重要资料以此...

论文辅导员
今天
8
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部