- 浏览: 520772 次
- 性别:
- 来自: 苏州
文章分类
- 全部博客 (152)
- Ajax总结 (10)
- JavaScript总结 (44)
- Java实用程序总结 (35)
- Spring总结 (10)
- Struts总结 (5)
- Hibernate学习 (3)
- 数据库学习 (9)
- CSS学习 (4)
- XML学习 (1)
- webservice (2)
- Java设计模式 (2)
- log4j (1)
- html (1)
- Jsp/Sevlet学习 (1)
- quartz学习 (1)
- tomcat (5)
- asm (0)
- maven (3)
- cloudstack (1)
- nginx (1)
- mysql (1)
- Redis (1)
- solr (2)
- rabbitmq (5)
- ELK (3)
最新评论
-
coosummer:
推荐使用http://buttoncssgenerator.c ...
几个比较好看的button的样式 -
thegod:
请问博主,计算平均成绩那个例子,“ // 将输入的数据首先按行 ...
hadoop的编程实例 -
微生物:
good
基于Maven的web项目在Eclipse中使用Tomcat调试 -
jacking124:
这个有这样一个问题,就是jsp-api包冲突!!
基于Maven的web项目在Eclipse中使用Tomcat调试 -
u010940863:
大神,这个工具类怎么用啊!求讲解啊!
Java创建和下载excel文件
Java并发编程-Executor
- 博客分类:
- Java实用程序总结
Executor框架是指java 5中引入的一系列并发库中与executor相关的一些功能类,其中包括线程池,Executor,Executors,ExecutorService,CompletionService,Future,Callable等。他们的关系为:
并发编程的一种编程方式是把任务拆分为一些列的小任务,即Runnable,然后在提交给一个Executor执行,Executor.execute(Runnalbe) 。Executor在执行时使用内部的线程池完成操作。
一、创建线程池
Executors类,提供了一系列工厂方法用于创先线程池,返回的线程池都实现了ExecutorService接口。
public static ExecutorService newFixedThreadPool(int nThreads)
创建固定数目线程的线程池。
public static ExecutorService newCachedThreadPool()
创建一个可缓存的线程池,调用execute 将重用以前构造的线程(如果线程可用)。如果现有线程没有可用的,则创建一个新线程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。
public static ExecutorService newSingleThreadExecutor()
创建一个单线程化的Executor。
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)
创建一个支持定时及周期性的任务执行的线程池,多数情况下可用来替代Timer类。
- Executor executor = Executors.newFixedThreadPool(10);
- Runnable task = new Runnable() {
- @Override
- public void run() {
- System.out.println("task over");
- }
- };
- executor.execute(task);
- executor = Executors.newScheduledThreadPool(10);
- ScheduledExecutorService scheduler = (ScheduledExecutorService) executor;
- scheduler.scheduleAtFixedRate(task, 10, 10, TimeUnit.SECONDS);
Executor executor = Executors.newFixedThreadPool(10); Runnable task = new Runnable() { @Override public void run() { System.out.println("task over"); } }; executor.execute(task); executor = Executors.newScheduledThreadPool(10); ScheduledExecutorService scheduler = (ScheduledExecutorService) executor; scheduler.scheduleAtFixedRate(task, 10, 10, TimeUnit.SECONDS);
二、ExecutorService与生命周期
ExecutorService扩展了Executor并添加了一些生命周期管理的方法。一个Executor的生命周期有三种状态,运行 ,关闭 ,终止 。Executor创建时处于运行状态。当调用ExecutorService.shutdown()后,处于关闭状态,isShutdown()方法返回true。这时,不应该再想Executor中添加任务,所有已添加的任务执行完毕后,Executor处于终止状态,isTerminated()返回true。
如果Executor处于关闭状态,往Executor提交任务会抛出unchecked exception RejectedExecutionException。
- ExecutorService executorService = (ExecutorService) executor;
- while (!executorService.isShutdown()) {
- try {
- executorService.execute(task);
- } catch (RejectedExecutionException ignored) {
- }
- }
- executorService.shutdown();
ExecutorService executorService = (ExecutorService) executor; while (!executorService.isShutdown()) { try { executorService.execute(task); } catch (RejectedExecutionException ignored) { } } executorService.shutdown();
三、使用Callable,Future返回结果
Future<V>代表一个异步执行的操作,通过get()方法可以获得操作的结果,如果异步操作还没有完成,则,get()会使当前线程阻塞。FutureTask<V>实现了Future<V>和Runable<V>。Callable代表一个有返回值得操作。
- Callable<Integer> func = new Callable<Integer>(){
- public Integer call() throws Exception {
- System.out.println("inside callable");
- Thread.sleep(1000);
- return new Integer(8);
- }
- };
- FutureTask<Integer> futureTask = new FutureTask<Integer>(func);
- Thread newThread = new Thread(futureTask);
- newThread.start();
- try {
- System.out.println("blocking here");
- Integer result = futureTask.get();
- System.out.println(result);
- } catch (InterruptedException ignored) {
- } catch (ExecutionException ignored) {
- }
Callable<Integer> func = new Callable<Integer>(){ public Integer call() throws Exception { System.out.println("inside callable"); Thread.sleep(1000); return new Integer(8); } }; FutureTask<Integer> futureTask = new FutureTask<Integer>(func); Thread newThread = new Thread(futureTask); newThread.start(); try { System.out.println("blocking here"); Integer result = futureTask.get(); System.out.println(result); } catch (InterruptedException ignored) { } catch (ExecutionException ignored) { }
ExecutoreService提供了submit()方法,传递一个Callable,或Runnable,返回Future。如果Executor后台线程池还没有完成Callable的计算,这调用返回Future对象的get()方法,会阻塞直到计算完成。
例子:并行计算数组的和。
- package executorservice;
- import java.util.ArrayList;
- import java.util.List;
- import java.util.concurrent.Callable;
- import java.util.concurrent.ExecutionException;
- import java.util.concurrent.ExecutorService;
- import java.util.concurrent.Executors;
- import java.util.concurrent.Future;
- import java.util.concurrent.FutureTask;
- public class ConcurrentCalculator {
- private ExecutorService exec;
- private int cpuCoreNumber;
- private List<Future<Long>> tasks = new ArrayList<Future<Long>>();
- // 内部类
- class SumCalculator implements Callable<Long> {
- private int[] numbers;
- private int start;
- private int end;
- public SumCalculator(final int[] numbers, int start, int end) {
- this.numbers = numbers;
- this.start = start;
- this.end = end;
- }
- public Long call() throws Exception {
- Long sum = 0l;
- for (int i = start; i < end; i++) {
- sum += numbers[i];
- }
- return sum;
- }
- }
- public ConcurrentCalculator() {
- cpuCoreNumber = Runtime.getRuntime().availableProcessors();
- exec = Executors.newFixedThreadPool(cpuCoreNumber);
- }
- public Long sum(final int[] numbers) {
- // 根据CPU核心个数拆分任务,创建FutureTask并提交到Executor
- for (int i = 0; i < cpuCoreNumber; i++) {
- int increment = numbers.length / cpuCoreNumber + 1;
- int start = increment * i;
- int end = increment * i + increment;
- if (end > numbers.length)
- end = numbers.length;
- SumCalculator subCalc = new SumCalculator(numbers, start, end);
- FutureTask<Long> task = new FutureTask<Long>(subCalc);
- tasks.add(task);
- if (!exec.isShutdown()) {
- exec.submit(task);
- }
- }
- return getResult();
- }
- /**
- * 迭代每个只任务,获得部分和,相加返回
- *
- * @return
- */
- public Long getResult() {
- Long result = 0l;
- for (Future<Long> task : tasks) {
- try {
- // 如果计算未完成则阻塞
- Long subSum = task.get();
- result += subSum;
- } catch (InterruptedException e) {
- e.printStackTrace();
- } catch (ExecutionException e) {
- e.printStackTrace();
- }
- }
- return result;
- }
- public void close() {
- exec.shutdown();
- }
- }
package executorservice; import java.util.ArrayList; import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.FutureTask; public class ConcurrentCalculator { private ExecutorService exec; private int cpuCoreNumber; private List<Future<Long>> tasks = new ArrayList<Future<Long>>(); // 内部类 class SumCalculator implements Callable<Long> { private int[] numbers; private int start; private int end; public SumCalculator(final int[] numbers, int start, int end) { this.numbers = numbers; this.start = start; this.end = end; } public Long call() throws Exception { Long sum = 0l; for (int i = start; i < end; i++) { sum += numbers[i]; } return sum; } } public ConcurrentCalculator() { cpuCoreNumber = Runtime.getRuntime().availableProcessors(); exec = Executors.newFixedThreadPool(cpuCoreNumber); } public Long sum(final int[] numbers) { // 根据CPU核心个数拆分任务,创建FutureTask并提交到Executor for (int i = 0; i < cpuCoreNumber; i++) { int increment = numbers.length / cpuCoreNumber + 1; int start = increment * i; int end = increment * i + increment; if (end > numbers.length) end = numbers.length; SumCalculator subCalc = new SumCalculator(numbers, start, end); FutureTask<Long> task = new FutureTask<Long>(subCalc); tasks.add(task); if (!exec.isShutdown()) { exec.submit(task); } } return getResult(); } /** * 迭代每个只任务,获得部分和,相加返回 * * @return */ public Long getResult() { Long result = 0l; for (Future<Long> task : tasks) { try { // 如果计算未完成则阻塞 Long subSum = task.get(); result += subSum; } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } return result; } public void close() { exec.shutdown(); } }
Main
- int[] numbers = new int[] { 1, 2, 3, 4, 5, 6, 7, 8, 10, 11 };
- ConcurrentCalculator calc = new ConcurrentCalculator();
- Long sum = calc.sum(numbers);
- System.out.println(sum);
- calc.close();
int[] numbers = new int[] { 1, 2, 3, 4, 5, 6, 7, 8, 10, 11 }; ConcurrentCalculator calc = new ConcurrentCalculator(); Long sum = calc.sum(numbers); System.out.println(sum); calc.close();
四、CompletionService
在刚在的例子中,getResult()方法的实现过程中,迭代了FutureTask的数组,如果任务还没有完成则当前线程会阻塞,如果我们希望任意字任务完成后就把其结果加到result中,而不用依次等待每个任务完成,可以使CompletionService。生产者submit()执行的任务。使用者take()已完成的任务,并按照完成这些任务的顺序处理它们的结果 。也就是调用CompletionService的take方法是,会返回按完成顺序放回任务的结果,CompletionService内部维护了一个阻塞队列BlockingQueue,如果没有任务完成,take()方法也会阻塞。修改刚才的例子使用CompletionService:
- public class ConcurrentCalculator2 {
- private ExecutorService exec;
- private CompletionService<Long> completionService;
- private int cpuCoreNumber;
- // 内部类
- class SumCalculator implements Callable<Long> {
- ......
- }
- public ConcurrentCalculator2() {
- cpuCoreNumber = Runtime.getRuntime().availableProcessors();
- exec = Executors.newFixedThreadPool(cpuCoreNumber);
- completionService = new ExecutorCompletionService<Long>(exec);
- }
- public Long sum(final int[] numbers) {
- // 根据CPU核心个数拆分任务,创建FutureTask并提交到Executor
- for (int i = 0; i < cpuCoreNumber; i++) {
- int increment = numbers.length / cpuCoreNumber + 1;
- int start = increment * i;
- int end = increment * i + increment;
- if (end > numbers.length)
- end = numbers.length;
- SumCalculator subCalc = new SumCalculator(numbers, start, end);
- if (!exec.isShutdown()) {
- completionService.submit(subCalc);
- }
- }
- return getResult();
- }
- /**
- * 迭代每个只任务,获得部分和,相加返回
- *
- * @return
- */
- public Long getResult() {
- Long result = 0l;
- for (int i = 0; i < cpuCoreNumber; i++) {
- try {
- Long subSum = completionService.take().get();
- result += subSum;
- } catch (InterruptedException e) {
- e.printStackTrace();
- } catch (ExecutionException e) {
- e.printStackTrace();
- }
- }
- return result;
- }
- public void close() {
- exec.shutdown();
- }
- }
public class ConcurrentCalculator2 { private ExecutorService exec; private CompletionService<Long> completionService; private int cpuCoreNumber; // 内部类 class SumCalculator implements Callable<Long> { ...... } public ConcurrentCalculator2() { cpuCoreNumber = Runtime.getRuntime().availableProcessors(); exec = Executors.newFixedThreadPool(cpuCoreNumber); completionService = new ExecutorCompletionService<Long>(exec); } public Long sum(final int[] numbers) { // 根据CPU核心个数拆分任务,创建FutureTask并提交到Executor for (int i = 0; i < cpuCoreNumber; i++) { int increment = numbers.length / cpuCoreNumber + 1; int start = increment * i; int end = increment * i + increment; if (end > numbers.length) end = numbers.length; SumCalculator subCalc = new SumCalculator(numbers, start, end); if (!exec.isShutdown()) { completionService.submit(subCalc); } } return getResult(); } /** * 迭代每个只任务,获得部分和,相加返回 * * @return */ public Long getResult() { Long result = 0l; for (int i = 0; i < cpuCoreNumber; i++) { try { Long subSum = completionService.take().get(); result += subSum; } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } return result; } public void close() { exec.shutdown(); } }
五、例子HtmlRender
该例子模拟浏览器的Html呈现过程,先呈现文本,再异步下载图片,下载完毕每个图片即显示,见附件eclipse项目htmlreander包。
所有代码见附件,Eclipse项目。本文参考《Java并发编程实践 》。
- concurrent.rar (21.2 KB)
- 下载次数: 3
发表评论
-
HttpClient请求调用封装
2014-04-04 16:35 26271. maven依赖包下载 <!-- httpcl ... -
Json转换工具类JsonUtil
2014-04-04 14:08 272521. maven依赖包下载 <!--json-li ... -
POI操作Excel文件
2014-03-14 12:01 13831. ExcelBean.java package com ... -
Java生成随机验证码
2014-02-27 18:03 8604package com.tg.snail.core.util ... -
hadoop的编程实例
2013-09-17 22:47 45505原文链接:http://www.cnblogs.c ... -
Array,List分页代码
2013-08-30 17:39 1712package com.snail.util; imp ... -
使用Google的Gson实现对象和json字符串之间的转换
2013-08-09 16:00 61713使用Google的Gson实现对象和json字符串之间的转换 ... -
一般加密和解密工具类
2013-07-12 16:38 1291package com.snail.util; im ... -
Java自带的MD5加密算法
2013-07-12 16:12 1651package com.snail.util; impo ... -
MD5加密
2011-12-14 13:03 762package com.config; import j ... -
Java实现的代码生成器
2011-09-09 13:23 2362package test; import java.io ... -
Java性能优化总结
2011-08-24 17:53 2082... -
Java读写文本文件操作
2011-07-27 13:52 2998package com.test; import jav ... -
Java创建和下载excel文件
2011-07-27 11:38 7763package com.g3.hrp.customer_s ... -
Java反射操作(需要commons-beanutils-1.8.2.jar)
2011-07-05 13:41 1084Java反射操作(需要commons-beanutils-1. ... -
正则表达式替换sql语句中的参数
2011-03-29 16:46 3652import java.util.ArrayList; im ... -
Java读取MAC地址
2011-02-15 09:41 1472Java读取MAC地址程序 package org.reve ... -
JAVA上传文件比较与实例
2010-11-12 16:26 4368JAVA上传文件比较与实例 jsp文件上传大多采用采用开源项目 ... -
图片工具类,完成图片的截取,缩放(ImageHepler )
2010-11-12 15:34 1193package com.lz.hr_picture.helpe ... -
Java定时执行某个任务
2009-03-23 17:07 1591Java定时执行某个任务
相关推荐
《Java并发编程的艺术》内容涵盖Java并发编程机制的底层实现原理、Java内存模型、Java并发编程基础、Java中的锁、并发容器和框架、原子类、并发工具类、线程池、Executor框架等主题,每个主题都做了深入的讲解,同时...
1.1 并发简史 1.2 线程的优势 1.2.1 发挥多处理器的强大能力 1.2.2 建模的简单性 1.2.3 异步事件的简化处理 1.2.4 响应更灵敏的用户界面 1.3 线程带来的风险 1.3.1 安全性问题 1.3.2 活跃性问题 1.3.3 ...
Java并发编程的艺术 作者:方腾飞 魏鹏 程晓明 著 丛书名:Java核心技术系列 出版日期 :2015-07-25 ISBN:978-7-111-50824-3 第1章介绍Java并发编程的挑战,向读者说明进入并发编程的世界可能会遇到哪些问题,以及如何...
Executor: 一个接口,其定义了一个接收Runnable对象的方法executor,其方法签名为executor(Runnable command),该方法接收一个Runable实例,它用来执行一个任务,任务即一个实现了Runnable接口的类,一般来说,...
, 《Java并发编程的艺术》内容涵盖Java并发编程机制的底层实现原理、Java内存模型、Java并发编程基础、Java中的锁、并发容器和框架、原子类、并发工具类、线程池、Executor框架等主题,每个主题都做了深入的讲解,...
本书的读者是那些具有一定Java编程经验的程序员、希望了解Java SE 5,6在线程技术上的改进和新特性的程序员,以及Java和并发编程的爱好者。 目录 代码清单 序 第1章 介绍 1.1 并发的(非常)简短历史 1.2 线程的...
1.1 并发简史 1.2 线程的优势 1.2.1 发挥多处理器的强大能力 1.2.2 建模的简单性 1.2.3 异步事件的简化处理 1.2.4 响应更灵敏的用户界面 1.3 线程带来的风险 1.3.1 安全性问题 1.3.2 活跃性问题 1.3.3 ...
Executor框架详解.mp4 实战:简易web服务器(一).mp4 实战:简易web服务器(二).mp4 JDK8的新增原子操作类LongAddr原理与使用.mp4 JDK8新增锁StampedLock详解.mp4 重排序问题.mp4 happens-before简单概述.mp4 锁的...
Java并发编程的艺术_非扫描本书特色本书结合JDK的源码介绍了Java并发框架、线程池的实现原理,帮助读者做到知其所以然。本书对原理的剖析不仅仅局限于Java层面,而是深入到JVM,甚至CPU层面来进行讲解,帮助读者从更...
龙果 java并发编程原理实战 第2节理解多线程与并发的之间的联系与区别 [免费观看] 00:11:59分钟 | 第3节解析多线程与多进程的联系以及上下文切换所导致资源浪费问题 [免费观看] 00:13:03分钟 | 第4节学习并发的四...
6.2 executor 框架 6.3 寻找可强化的并行性 第7章 取消和关闭 7.1 任务取消 7.2 停止基于线程的服务 7.3 处理反常的线程终止 7.4 jvm关闭 第8章 应用线程池 8.1 任务与执行策略问的隐性耦合 8.2 定制线程池的大小 ...
java7在并发编程方面,带来了很多令人激动的新功能,这将使你的应用程序具备更好的并行任务性能。 《Java 7并发编程实战手册》是Java 7并发编程的实战指南,介绍了Java 7并发API中大部分重要而有用的机制。全书分为9...
详细介绍java并发编程相关知识: 基础知识 并发与并行 Java并发演进历史 Java并发模型 线程模型 存储模型 JVM同步原语 volatile CAS 线程安全 保护“共享数据” 低级并发工具 原子变量 锁...
java 并发 编程 多线程 concurrent lock condition executorserice executor java.util.curcurrent.
│ Java并发编程.png │ ppt+源码.rar │ 高并发编程第二阶段01讲、课程大纲及主要内容介绍.wmv │ 高并发编程第二阶段02讲、介绍四种Singleton方式的优缺点在多线程情况下.wmv │ 高并发编程第二阶段03讲、...