java 线程池
2016-07-22 11:23
453 查看
先来讲讲什么是并发线程,并发编程是我们可以将程序划分为多个分离或独立运行的任务。通过使用多线程机制,这些子任务中的每一个都将由执行线程来驱动。一个线程就是在进程中的一个单一的循序控制流,因此,单一进程可以拥有多个并发执行任务,但是你的程序使得每个任务都好像有自己的CPU一样。
public class Liftoff implements Runnable {
private String name;
public Liftoff(String name){
this.name=name;
}
@Override
public void run() {
// TODO Auto-generated method stub
//每个线程打印10次
for(int i=1;i<10;i++){
System.out.println(i+name);
}
}
}
线程池几种方法
(1)创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收
ExecutorService executorService = Executors.newCachedThreadPool();
String [] name={"A","B","C"};
for(int i=0;i<3;i++){
executorService.execute(new Liftoff(name[i]));
}
executorService.shutdown();、
运行结果 1A,1C,2C,3C,4C,5C,6C,7C,8C,9C,2A,3A,1B,4A,2B,3B,4B,5B,6B,5A,7B,8B,9B,6A,7A,8A,9A,
(2)创建固定大小的线程池。每次提交一个任务就创建一个线程,直到线程达到线程池的最大大小。线程池的大小一旦达到最大值就会保持不变,如果某个线程因为执行异常而结束,那么线程池会补充一个新线程
ExecutorService executorService = Executors.newFixedThreadPool(3);
String [] name={"A","B","C"};
for(int i=0;i<3;i++){
executorService.execute(new Liftoff(name[i]));
}
executorService.shutdown();、
运行结果 1A,2A,3A,4A,5A,1C,2C,3C,1B,4C,5C,6C,6A,7A,8A,9A,7C,8C,9C,2B,3B,4B,5B,6B,7B,8B,9B,
(3)创建一个单线程的线程池。这个线程池只有一个线程在工作,也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行
ExecutorService executorService = Executors.newSingleThreadExecutor();
String [] name={"A","B","C"};
for(int i=0;i<3;i++){
executorService.execute(new Liftoff(name[i]));
}
executorService.shutdown();、
运行结果 1A,2A,3A,4A,5A,6A,7A,8A,9A,1B,2B,3B,4B,5B,6B,7B,8B,9B,1C,2C,3C,4C,5C,6C,7C,8C,9C,
(4) 创建一个大小无限的线程池。此线程池支持定时以及周期性执行任务的需求。
ExecutorService executorService = Executors.newScheduledThreadPool(3);
String [] name={"A","B","C"};
for(int i=0;i<3;i++){
executorService.execute(new Liftoff(name[i]));
}
executorService.shutdown();、
运行结果 1A,2A,3A,4A,5A,6A,7A,8A,9A,1B,1C,2B,2C,3B,3C,4B,4C,5B,5C,6B,6C,7B,7C,8B,8C,9B,9C,
public class Liftoff implements Runnable {
private String name;
public Liftoff(String name){
this.name=name;
}
@Override
public void run() {
// TODO Auto-generated method stub
//每个线程打印10次
for(int i=1;i<10;i++){
System.out.println(i+name);
}
}
}
线程池几种方法
(1)创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收
ExecutorService executorService = Executors.newCachedThreadPool();
String [] name={"A","B","C"};
for(int i=0;i<3;i++){
executorService.execute(new Liftoff(name[i]));
}
executorService.shutdown();、
运行结果 1A,1C,2C,3C,4C,5C,6C,7C,8C,9C,2A,3A,1B,4A,2B,3B,4B,5B,6B,5A,7B,8B,9B,6A,7A,8A,9A,
(2)创建固定大小的线程池。每次提交一个任务就创建一个线程,直到线程达到线程池的最大大小。线程池的大小一旦达到最大值就会保持不变,如果某个线程因为执行异常而结束,那么线程池会补充一个新线程
ExecutorService executorService = Executors.newFixedThreadPool(3);
String [] name={"A","B","C"};
for(int i=0;i<3;i++){
executorService.execute(new Liftoff(name[i]));
}
executorService.shutdown();、
运行结果 1A,2A,3A,4A,5A,1C,2C,3C,1B,4C,5C,6C,6A,7A,8A,9A,7C,8C,9C,2B,3B,4B,5B,6B,7B,8B,9B,
(3)创建一个单线程的线程池。这个线程池只有一个线程在工作,也就是相当于单线程串行执行所有任务。如果这个唯一的线程因为异常结束,那么会有一个新的线程来替代它。此线程池保证所有任务的执行顺序按照任务的提交顺序执行
ExecutorService executorService = Executors.newSingleThreadExecutor();
String [] name={"A","B","C"};
for(int i=0;i<3;i++){
executorService.execute(new Liftoff(name[i]));
}
executorService.shutdown();、
运行结果 1A,2A,3A,4A,5A,6A,7A,8A,9A,1B,2B,3B,4B,5B,6B,7B,8B,9B,1C,2C,3C,4C,5C,6C,7C,8C,9C,
(4) 创建一个大小无限的线程池。此线程池支持定时以及周期性执行任务的需求。
ExecutorService executorService = Executors.newScheduledThreadPool(3);
String [] name={"A","B","C"};
for(int i=0;i<3;i++){
executorService.execute(new Liftoff(name[i]));
}
executorService.shutdown();、
运行结果 1A,2A,3A,4A,5A,6A,7A,8A,9A,1B,1C,2B,2C,3B,3C,4B,4C,5B,5C,6B,6C,7B,7C,8B,8C,9B,9C,
相关文章推荐
- Spring Web利用切面统一处理参数校验异常的方法
- 关于Spring中加载xsd文件出现故障的文章总结
- 61. mybatic insert异常:BindingException: Parameter 'name' not found【从零开始学Spring B】
- Java服务器与客户端的通信中对象流的使用
- 用mybatis实现模糊查询
- Java之详解坦克大战游戏(三)
- Java-JVM优化
- 更改jdk的路径
- org.springframework.beans.factory.BeanCreationException
- Java中八种基本数据类型的默认值
- 使用maven插件对java工程进行打包
- spring 定时任务调用存储过程配置示例(未测试)
- Ubuntu命令行自动下载安装配置Java环境
- Ubuntu使用(二)——eclipse配置与问题
- Windows7下JavaEE(jsp开发环境)快速搭建+第一个jsp程序 超详细教程
- 4000 SpringMVC+uploadify3.2.1版实现附件上传功能(未测试)
- java 内部类作用
- java 线程的学习
- 《Java源码分析》:Vector
- Spring + RMI