线程池+FutureTask执行多任务计算
public class Test {
//线程池最好作为全局变量, 若作为局部变量记得用完后shutdown()
ThreadFactory namedThreadFactory = new ThreadFactoryBuilder(）.setNameFormat('thread-start-runner-%d').build();
ExecutorService taskExe= new ThreadPoolExecutor(10,20,800L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue(100),namedThreadFactory);
int count=0;
@Test
public void test(String[] args) {
//任务列表
List> taskList=new ArrayList>();
for(int i=0;i<100;i++){
//创建100个任务放入【任务列表】
FutureTask futureTask=new FutureTask(new Callable() {
@Override
public Integer call() throws Exception {
return 1;
}
});
//执行的结果装回原来的FutureTask中,后续直接遍历集合taskList来获取结果即可
taskList.add(futureTask);
taskExe.submit(futureTask);
}
//获取结果
try{
for(FutureTask futureTask:taskList){
count+=futureTask.get();
}
} catch (InterruptedException e) {
logger.error('线程执行被中断',e);
} catch (ExecutionException e) {
logger.error('线程执行出现异常',e);
}
//关闭线程池
taskExe.shutdown();
//打印: 100
System.out.println(count);
}
} 解决方案：
FutureTask内部的run()代码块会把异常给吞进去，通过setException(Throwablet)把异常赋给了对象outcome，我们在调用FutureTasget()获取结果的时候返回的就是这个对象
如果你的代码没有调用FutureTasget()，它不会把异常吐出来，有可能子线程就莫名的停止了。
public Future submit(Runnable task) {
if (task == null) throw new NullPointerException();
//创建一个异步执行的任务FutureTask, 【隐患】也在它的run()代码块里
RunnableFuture ftask = newTaskFor(task, null);
execute(ftask);
return ftask;
} 上一篇：大规模业务技术架构设计与战术
submit(Runnabletas提交任务的方式，是存在“隐患”的：
用线程池+FutureTask将1个查询拆分成多个小查询，选择FutureTask是因为它具有仅执行1次run()方法的特性(即使有多次调用也只执行1次)，避免了重复查询的可能。而且多任务异步执行也能提高接口响应速度。
本文主要讲的是线程池搭配FutureTask异步执行的例子
子线程出的异常抛不出的情况
Callable接口能让我们拿到线程的执行结果，所以让它作为FutureTask构造函数FutureTask(Callable
上面的例子没有这个问题，因为调用了FutureTasget()，有异常会从这里拿出来
FutureTask执行的结果会放入它的私有变量outcome中，其他线程直接调用futureTasget()去读取该变量即可
文章为作者独立观点，不代表股票交易接口观点
股民评论