1.线程池的意义:线程池可以有效的管理线程和减少开启线程和关闭线程的时间消耗。
2.典型的线程池:线程池管理器,工作线程,请求接口,请求队列,结果队列
3.Java自带的线程池服务:
4.Java通过Executors类可以创建四种线程池,他们分别是newCachedThreadPool,newFixedThreadPool,newScheduledThreadPool,newSingleThreadExecutor
newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。
newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。
newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行。
newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。
5.线程池的创建:
比如创建newCachedThreadPool:ExecutorService service =Executors.newCachedThreadPool();
6.线程的提交
线程的提交方式有两种:submit(),excute(),这两个是有区别的,使用submit的时候可以提交三种方式生成的线程,即实现Runnable,实现Callable,继承Thread,并且可以返回数值,但是excute提交方式只能接受实现Callable方式的线程并不可以有返回值
7.线程池的关闭
线程池的关闭可以使用两种方式:shutdown()和shutdownnow(),shutdown关闭的时候允许之前提交的线程执行完毕再关闭线程池,而shutdownnow为阻止等待任务启动并试图停止当前正在执行的任务。
8.Runnable()与Callable()区别
两者和Thread都可以成为创建线程的一种方式,Runnable,Callable都是接口,Thread是一个抽象类。创建线程的时候,如果是实现的Runnable或者继承的Thread,则需要实现run方法,而实现Callable时,需要实现call方法;通过实现Callable方法创建线程的时候,会增加一个泛型,通过该泛型可以指定call方法的返回类型,call()方法的返回值可以通过 Future类的get()方法获取。
给一个Callable的列子:
package com.mvn.test9;
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;
public class CallThread implements Callable<String>{
private int thid;
public CallThread(int thid){
this.thid=thid;
}
public String call() throws Exception {
for(int i=0;i<100;i++){
System.out.println("线程id["+thid+"] 第"+i+"次执行!");
}
return "线程id["+thid+"] 执行完毕!";
}
public static void main(String[] args) {
ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(3);
List<Future<String>> fl=new ArrayList<Future<String>>();
for(int i=0;i<3;i++){
CallThread ct=new CallThread((i+1));
Future<String> future = newFixedThreadPool.submit(ct);
fl.add(future);
}
newFixedThreadPool.shutdown();
for(Future<String> future:fl){
try {
System.out.println(future.get());
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ExecutionException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}