线程池的创建与获取
2015-09-06 20:10
363 查看
线程池的获取
package day19; 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();//不再接收新的任务,尝试关闭所有任务 } }
相关文章推荐
- 9月21日锁定期还没到,马云就开始套现了
- 构建需求响应式亿级商品详情页
- Linux代码中添加System Pause 断点
- WinPAI: FindWindow、FindWindowEx ---查找窗口
- 数组输出
- eclipse格式化代码快捷键无效与搜狗输入法莫名变为繁体
- XSLT
- 字符串输入输出
- MySQL表名、列名区分大小写详解
- hdu 5427 A problem of sorting
- CSS3:3D转换
- [HDOJ5288]OO's Sequence
- 数据结构:表、栈、和队列(1)——抽象数据类型
- Android实例-MediaPlayer播放音乐和视频(XE8+小米2)
- 随笔
- 电脑中文环境变量设置
- 冒泡法排序
- poj 3468 A Simple Problem with Integers || 线段树
- HD 5428 The Factor
- UpdateData、Invalidate、InvalidateRect和UpdateWindow及RedrawWindow