java~线程池的总结

线程的创建和效率都需要消耗处理器（cpu）的资源，所以我们在使用线程时需要注意，你的每一个动作都是需要为它买单的，也正是因为线程的使用需要谨慎，所以java对线程的管理也进行了封装，就是今天要说的线程池，目前java主要封装了大概４大种类型的线程池，下面简单来介绍一下。

四大类型的线程池

1. newcachedthreadpool创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收，则新建线程。
2. newfixedthreadpool 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。
3. newscheduledthreadpool 创建一个定长线程池，支持定时及周期性任务执行。
4. newsinglethreadexecutor 创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序(fifo, lifo, 优先级)执行。

线程池里主要的三个参数

corepoolsize：
线程池的基本大小，即在没有任务需要执行的时候线程池的大小，并且只有在工作队列满了的情况下才会创建超出这个数量的线程。这里需要注意的是：在刚刚创建threadpoolexecutor的时候，线程并不会立即启动，而是要等到有任务提交时才会启动，除非调用了prestartcorethread/prestartallcorethreads事先启动核心线程。再考虑到keepalivetime和allowcorethreadtimeout超时参数的影响，所以没有任务需要执行的时候，线程池的大小不一定是corepoolsize。
maximumpoolsize：
线程池中允许的最大线程数，线程池中的当前线程数目不会超过该值。如果队列中任务已满，并且当前线程个数小于maximumpoolsize，那么会创建新的线程来执行任务。这里值得一提的是largestpoolsize，该变量记录了线程池在整个生命周期中曾经出现的最大线程个数。为什么说是曾经呢？因为线程池创建之后，可以调用setmaximumpoolsize()改变运行的最大线程的数目。
poolsize：
线程池中当前线程的数量，当该值为0的时候，意味着没有任何线程，线程池会终止；同一时刻，poolsize不会超过maximumpoolsize。

相关实例代码

newcachedthreadpool缓存池

 /**
   * newcachedthreadpool线程自动分配，不能控制上限.
   */
  @test
  public void newcachedthreadpool() {
    executorservice cachedthreadpool = executors.newcachedthreadpool();
    for (int i = 0; i < 20; i++) {
      cachedthreadpool.execute(new runnable() {
        @override
        public void run() {
          logger.info("cachedthreadpool测试代码:{}", thread.currentthread().getname());
        }
      });
    }
  }

newfixedthreadpool可控制上线的线程池

  /**
   * newfixedthreadpool控制最大的线程数，可以控制上限.
   */
  @test
  public void newfixedthreadpool() {
    executorservice fixedthreadpool = executors.newfixedthreadpool(5);
    for (int i = 0; i < 20; i++) {
      fixedthreadpool.execute(new runnable() {
        @override
        public void run() {
          logger.info("fixedthreadpool测试代码:{}", thread.currentthread().getname());
        }
      });
    }
  }

newsinglethreadexecutor只有一个线程的线程池，只有当线程出现异常后才会建立新的线程代替它

  /**
   * newsinglethreadexecutor只有一个线程，当这个线程因为异常结束，会有一个新的线程来替代它.
   */
  @test
  public void newsinglethreadexecutor() {
    executorservice newsinglethread = executors.newsinglethreadexecutor();
    for (int i = 0; i < 20; i++) {
      newsinglethread.execute(new runnable() {
        @override
        public void run() {
          logger.info("newsinglethread测试代码:{}", thread.currentthread().getname());
        }
      });
    }
  }

newscheduledthreadpool带有调度功能的线程池，可以执行周期性的任务

/**
   * newscheduledthreadpool按着时间间隔进行周期性任务
   */
  @test
  public void newscheduledthreadpool() throws interruptedexception {
    scheduledexecutorservice executor = executors.newscheduledthreadpool(5);
    executor.scheduleatfixedrate(() -> {
      long start = new date().gettime();
      system.out.println("scheduleatfixedrate 开始执行时间:" +
          dateformat.gettimeinstance().format(new date()));
      try {
        thread.sleep(1000);
      } catch (interruptedexception e) {
        e.printstacktrace();
      }
      long end = new date().gettime();
      system.out.println("scheduleatfixedrate 执行花费时间=" + (end - start) / 1000 + "m");
      system.out.println("scheduleatfixedrate 执行完成时间：" + dateformat.gettimeinstance().format(new date()));
      system.out.println("======================================");
    }, 0, 1, timeunit.seconds);//initialdelay初始化延时,period:两次执行最小间隔时间

    thread.sleep(1000 * 10);
  }