JDK自带的线程池

时间:2021-03-09 15:18:34

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();
            }
        }
    }

}