zoukankan      html  css  js  c++  java
  • Executor框架

    为了更好的控制多线程,JDK提供了一套线程框架Executor,帮助开发人员有效的进行线程控制。他们都在Java.utilconcurrent包中,是JDK并发包的核心。其中有一个比较重要的类:Executors,他扮演着线程工厂的角色,我们通过Executors可以创建特定功能的线程池。

    Executor创建线程池的方法:

      newFixedThreadPool()方法,该方法返回一个固定数量的线程池,该方法的线程数量始终不变,当有一个任务提交时,若线程池中空闲,则立即只执行,若没有,则会被暂缓在一个任务队列中等待有空闲的线程去执行。

    1   public static ExecutorService newFixedThreadPool(int nThreads) {
    2         return new ThreadPoolExecutor(nThreads, nThreads,
    3                                       0L, TimeUnit.MILLISECONDS,
    4                                       new LinkedBlockingQueue<Runnable>());//无界的
    5     }

      newSingleThreadExecutor()方法,创建一个线程的线程池,若空闲则执行,若没有空闲线程,则暂缓在任务队列中。

    1  public static ExecutorService newSingleThreadExecutor() {
    2         return new FinalizableDelegatedExecutorService
    3             (new ThreadPoolExecutor(1, 1,
    4                                     0L, TimeUnit.MILLISECONDS,
    5                                     new LinkedBlockingQueue<Runnable>()));//无界的
    6     }

      newCachedThreadPool()方法,返回一个可根据实际情况调整线程个数的线程池。不限制最大线程数量,若用空闲的线程执行任务,则无任务则不创建线程,并且每一个空线程会在60s后自动回收。(核心线程数为0,带缓存的线程池(60L))

    1  public static ExecutorService newCachedThreadPool() {
    2         return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
    3                                       60L, TimeUnit.SECONDS,
    4                                       new SynchronousQueue<Runnable>());//缓存队列长度为0,只要来一个任务,立马交给线程去执行,任务先取后放
    5     }

      newScheduledThreadPool()方法,该方法返回一个SchededExcutorService对象,但该线程池可以指定线程的数量。

    1  private class ScheduledFutureTask<V>
    2             extends FutureTask<V> implements RunnableScheduledFuture<V> {
     1  public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
     2         return new ScheduledThreadPoolExecutor(corePoolSize);
     3     }
     4 
     5 
     6 
     7 
     8  public ScheduledThreadPoolExecutor(int corePoolSize) {
     9         super(corePoolSize, Integer.MAX_VALUE, 0, TimeUnit.NANOSECONDS,
    10               new DelayedWorkQueue());
    11     }
     1  public static ScheduledExecutorService newScheduledThreadPool(
     2             int corePoolSize, ThreadFactory threadFactory) {
     3         return new ScheduledThreadPoolExecutor(corePoolSize, threadFactory);
     4     }
     5 
     6 
     7 
     8  public ScheduledThreadPoolExecutor(int corePoolSize,
     9                                        ThreadFactory threadFactory) {
    10         super(corePoolSize, Integer.MAX_VALUE, 0, TimeUnit.NANOSECONDS,
    11               new DelayedWorkQueue(), threadFactory);
    12     }

      上面四个对象,其底层都是实例化了一个ThreadPoolExecutor

    类Executors工厂类无法满足我们的需求,可以自己去创建自定义的线程池,其实Eexcutors工厂类里面的创建线程方法其内部实现均是用了ThreadPoolExecutor这个类,这个类可以自定义线程。构造方法如下:

    public ThreadPoolExecutor(int corePoolSize,//当前核心线程数,表示线程池一旦初始化,就存在了corePoolSize个线程

                  int maximumPoolSize,

                  long keepAliveTime,

                  TimeUnit unit,

                  BlockingQueue<Runnable>workQueue,

                  ThreadFactory threadFactory,

                  RejectedExecutionHandler handler){...}



    自定义线程池使用详细:  这个构造方法对于队列是什么类型比较关键:

      在使用有界队列时,若有新的任务需要执行,如果线程池实际线程数小于corePoolSize,则优先创建线程,若大于corePoolSize,则会将任务加入队列,若队列已满,则在总线程数不大于maximumPoolSize的前提下,创建新的线程,若线程数大于maximumPoolSize,则执行拒绝策略。或其他自定义的方式。

      无界的任务队列时,LinkedBlockingQueue。与有界队列相比,除非系统资源耗尽,否则无界的任务队列不存在任务入队失败的情况。当有新任务到来,系统的线程数小于corePoolSize后,就不会继续增加。若后续仍有新的任务加入,而又没有空闲的线程资源,则任务直接进入队列等待。若任务创建和处理的速度差异很大,无界队列会保持快速增长,直到耗尽系统内存。

    JDK拒绝策略:

      AbortPolicy:直接抛出异常组织系统正常工作

      CallerRunsPolicy:只要线程池未关闭,该策略直接在调用者线程中,运行当前被丢弃的任务

      DiscardOldestPolicy:丢弃最老的一个请求,尝试再次提交当前任务。

      DiscardPolicy:丢弃无法处理的任务,不给予任何处理。

    如果需要自定义拒绝策略可以实现RejectedExecutionHandler接口

      

  • 相关阅读:
    [转]UTF-8网页中的头部部分多出一行空白
    php json josn_decode()返回的是对像,如何把对像转成数组
    php file_get_contents计时读取一个文件/页面 防止读取不到内容
    java基础知识 构造方法
    Java基础知识Set、List、Map的区别
    Java基础知识 Set
    java基础语法 List
    java基础语法 数组
    java基础语法this关键字
    http webservice socket的区别
  • 原文地址:https://www.cnblogs.com/syousetu/p/6759622.html
Copyright © 2011-2022 走看看