线程池的创建与使用
2015-09-06 20:16
453 查看
线程池的创建与使用
package ThreadPoolDemo; 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; public class ThreadPoolDemo01 { static class Task01 implements Runnable{ @Override public void run() { try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } String taskName=Thread.currentThread().getName(); System.out.println(taskName+"-->Task01"); } } public static void main(String[] args) throws Exception {//队列形式的线程池 ExecutorService es=null; //创建一个只有一个线程的线程池 //es=Executors.newSingleThreadExecutor();//常用 //创建指定上限的线程池 es=Executors.newFixedThreadPool(3);//常用,数字是经验值,根据现在情况有多少人会在线 ////创建没有指定上限的线程池(上限由系统决定) //es=Executors.newCachedThreadPool(); System.out.println("es: "+es); //从线程池取线程执行任务 //多个任务会放到任务列表中 /*es.execute(new Task01()); es.execute(new Task01()); es.execute(new Task01());*/ es.execute(new Task01()); //当需要从某个任务获得一个结果时 //经常采用如下方式执行任务,将要执行的Task任务Callable<Integer>的执行结果 Future<Integer> f=es.submit(new Callable<Integer>() { @Override public Integer call() throws Exception { Thread.sleep(3000); return 300; } }); //f.get()用于获得任务执行的结果 //此方法是一个阻塞死方法(任务没有结束时它会抛出异常) //这是主线程中执行的方法 System.out.println(f.get()); es.shutdown();//不再接收新的任务。等待所有任务执行结束 //es.shutdownNow();//不再接收新的任务,尝试关闭所有任务 } }
相关文章推荐
- android popupwindow showAsDropDown offsetx无效的问题
- 1004. 成绩排名 (20)
- UNIX域套接字(unix domain)
- Eclipse导入Android项目步骤
- Oracle RMAN active 克隆数据库
- CentOS下php通过SQLCipher编译sqlite3支持数据库加密
- CSAPP读书笔记——程序的机器级表示之寄存器分布与mov指令集
- 字符串hash,bzoj2795[Poi2012]A Horrible Poem
- Processing 教程(9)面向对象 - 从未如此明了
- 安装protocolbuffer详解
- 《淘宝技术这十年》读书笔记
- Namespaces(命名空间)
- poj2135最小费用最大流经典模板题
- HDU 1175 连连看(DFS)
- 基于S3C2410A的WINCE下Stepldr程序移植详细分析
- backbone学习笔记(1)
- JavaScript面试题
- windows 64 位系统下cv2.videocapture失败的问题
- 分布式系统 淘宝数据魔方技术架构解析
- LDO-AMS1117