java.util.concurrent 学习笔记---线程池模块

     广义上的完整线程池可能还包括Thread/Runnable、Timer/TimerTask等部分。这里只介绍主要的和高级的API和类。ThreadPool2_2.png (1024×513)工具

 

 

Executor-class_2.png (811×765)

            Executors

            此类是个工具类(工厂类),它提供对Executor、ExecutorService、ScheduledExecutorService、ThreadFactory 和 Callable 类的一些实用方法。spa

            对ExecutorService类的初始化线程

             ExecutorService newCachedThreadPool()htm

                初始化0个线程,最大线程数为Integer.MAX_VALUEget

             ExecutorService   newCachedThreadPool(ThreadFactory threadFactory)it

                      初始化0个线程,最大线程数为Integer.MAX_VALUEio

             ExecutorService newFixedThreadPool(int nThreads) :class

                    建立大小固定的线程执行者(初始化nThreads个线程,最大线程数为nThreads)thread

             ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory):配置

                    建立大小固定的线程执行者(初始化nThreads个线程,最大线程数为nThreads)

            ExecutorService newSingleThreadExecutor():

                    建立一个线程执行者(初始化1个线程,最大线程数为1)

            ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory):

                     建立一个线程执行者(初始化1个线程,最大线程数为1)

            

            ScheduledExecutorService newScheduledThreadPool(int corePoolSize)

                    建立一个调度任务线程执行者

            ScheduledExecutorService newScheduledThreadPool(int corePoolSize, ThreadFactory threadFactory)

                    建立一个调度任务线程执行者

            AbstractExecutorService

            <T> Future<T> submit(Callable<T> task):

                    提交一个 Callable任务用于执行,并返回一个表示该任务的 Future。

             Future<?> submit(Runnable task)

                    提交一个 Runnable任务用于执行,并返回一个表示该任务的 Future。

            <T> Future<T> submit(Runnable task, T result)

                    提交一个 Runnable任务用于执行,并返回一个表示该任务的 Future。

            <T> T invokeAny(Collection<? extends Callable<T>> tasks)

                    执行给定的任务,若是某个任务已成功完成(也就是未抛出异常),则返回其结果。一旦正常或异常返回后,则取消还没有完成的任务。若是此操做正在进行时修改了给定的集合,则此方法的结果是不明确的。

            <T> T invokeAny(Collection<? extends Callable<T>> tasks,
                       long timeout, TimeUnit unit)

                    执行给定的任务,若是某个任务已成功完成(也就是未抛出异常),则返回其结果。一旦正常或异常返回后,则取消还没有完成的任务。若是此操做正在进行时修改了给定的集合,则此方法的结果是不明确的。(此方法执行全部任务,并返回第一个完成(未超时)且没有抛出异常的任务的结果)

         <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)

                    执行给定的任务,当全部任务完成时,返回保持任务状态和结果的 Future 列表。返回列表的全部元素的 Future.isDone() 为 true。注意,能够正常地或经过抛出异常来终止已完成 任务。若是正在进行此操做时修改了给定的集合,则此方法的结果是不明确的。

        <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                                     long timeout, TimeUnit unit)

                此方法执行全部任务,当它们所有完成且未超时,返回它们的执行结果。

            ThreadPoolExecutor 类

            此类是线程池类,

            经常使用方法:

            void execute(Runnable command)

            关闭线程池

            void shutdown()            

            List<Runnable> shutdownNow()

            boolean isTerminated():若是你已经调用shutdown()或shutdownNow()方法,而且执行者完成关闭它的处理时,此方法返回true。

              boolean isShutdown():若是你在执行者中调用shutdown()方法,此方法返回true。

              boolean awaitTermination(long timeout, TimeUnit unit):此方法阻塞调用线程,直到执行者的任务结束或超时

            状态类

            int getPoolSize():此方法返回线程池实际的线程数

            int getActiveCount():此方法返回在执行者中正在执行任务的线程数

            int getCompletedTaskCount():此方法返回执行者完成的任务数

            int getLargestPoolSize():此方法,返回池中某一时刻最大的线程数

 

            boolean awaitTermination(long timeout, TimeUnit unit)

                    等待线程执行完毕
                 

 

            ScheduledThreadPoolExecutor 

                给定的延迟后运行命令,或者按期执行命令。须要多个辅助线程时,或者要求 ThreadPoolExecutor 具备额外的灵活性或功能时,此类要优于 Timer。

                

         ScheduledFuture<?> schedule(Runnable command,long delay,TimeUnit unit)

               在给定的延迟后,建立和执行Runnabel。

         ScheduledFuture<V> schedule(Callable<V> callable,long delay,TimeUnit unit) 

                        在给定的延迟后,建立和执行Callable。

            void setExecuteExistingDelayedTasksAfterShutdownPolicy(boolean value):

                    当你调用shutdown()方法时,而且有待处理的任务正在等待它们延迟结束。默认的行为是,无论执行者是否结束这些任务都将被执行,使用false,调用 shutdown()时,待处理的任务不会被执行。

            

 

            ScheduledFuture<?> scheduleAtFixedRate(Runnable command,long initialDelay,long period,TimeUnit unit)

                    周期性的执行任务(你想要周期性执行的任务、第一次执行任务的延迟时间、两次执行之间的间隔期间、第二、3个参数的时间单位)

            ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,long initialDelay,long delay,TimeUnit unit) 

                    在任务结束后固定的时间周期性执行任务(你想要周期性执行的任务、第一次执行任务的延迟时间、参数决定任务执行结束与下次执行开始之间的一段时间、第二、3个参数的时间单位)           

   

            void setContinueExistingPeriodicTasksAfterShutdownPolicy(boolean value)

                    当你使用 shutdown()方法时,你也能够经过参数配置一个SeduledThreadPoolExecutor的行为。shutdown()方法默认的行为是,当你调用这个方法时,计划任务就结束。 你能够使用ScheduledThreadPoolExecutor类的 setContinueExistingPeriodicTasksAfterShutdownPolicy()方法设置true值改变这个行为。在调用 shutdown()方法时,周期性任务将不会结束。