首页 > 代码库 > java 的线程池介绍

java 的线程池介绍

参考文献: http://www.jianshu.com/p/87bff5cc8d8c

                   http://www.jianshu.com/p/edd7cb4eafa0

在Java应用中如果需要频繁的去创建大量线程去完成任务,肯定会对性能有很大的影响。因为系统在创建和销毁线程上需要消耗太多的资源,开销很大。

所以在这种情况下可以考虑线程池。有以下优点:

1) 降低资源消耗 :通过重复利用已创建的线程降低线程创建和销毁造成的消耗;

2)提高响应速度 : 当任务到达时,任务可以不需要等到线程创建就能立即执行;

3)提高线程的可管理型: 线程是稀缺资源,如果无限制的创建,不仅会消耗系统资源,还会降低系统的稳定性,使用线程池可以进行统一的分配,调优和监控

 

在Java1.5中引入的Executor框架中定义了四种创建线程池的方法:

一、newFixedThreadPool

private static Executor executor = Executors.newFixedThreadPool(10);

 固定型线程池,和newCacheThreadPool()差不多,也能够实现resue(复用),但是这个池子规定了线程的最大数量,也就是说当池子有空闲时,那么新的任务将会在空闲线程中被执行,一旦线程池内的线程都在进行工作,那么新的任务就必须等待线程池有空闲的时候才能够进入线程池,其他的任务继续排队等待.这类池子没有规定其空闲的时间到底有多长.这一类的池子更适用于服务器

二、newCachedThreadPool

private static Executor executor1 = Executors.newCachedThreadPool();

缓存线程池,先查看线程池中是否有当前执行线程的缓存,如果有就resue(复用),如果没有,那么需要创建一个线程来完成当前的调用.并且这类线程池只能完成一些生存期很短的一些任务.并且这类线程池内部规定能resue(复用)的线程,空闲的时间不能超过60s,一旦超过了60s,就会被移出线程池

三、newSingleThreadExecutor

private static Executor executor2 = Executors.newSingleThreadExecutor();

初始化的线程池中只有一个线程,如果该线程异常结束,会重新创建一个新的线程继续执行任务,唯一的线程可以保证所提交任务的顺序执行,内部使用LinkedBlockingQueue作为阻塞队列。

四、newScheduledThreadPool

private static Executor executor3 = Executors.newScheduledThreadPool(10);

调度型线程池,调度型线程池会根据Scheduled(任务列表)进行延迟执行,或者是进行周期性的执行.适用于一些周期性的工作.

 

创建完任务后需要提交运行,在线程池框架中提供了两种提交方法:

一、Executor.execute()

       通过execute方法提交的参数必须要实现Runnable接口,任务在run方法中执行,该种方法提交的任务没有返回值。

 //无返回值
    static class Task implements Runnable{
        @Override
        public void run(){
                System.out.print(Thread.currentThread().getName());
        }
    }

 

二、ExecutorService.submit()

        通过submit方法提交的参数中需要实现Callable接口,任务在call方法中执行,该种方法有返回值,可以通过返回值来判断任务的执行状态。

//有返回值
    static class callTask implements Callable<String>{
        @Override
        public String call(){
            return (Thread.currentThread().getName());
        }
    }

 

java 的线程池介绍