code: public static ThreadPoolExecutor newFixedThreadPool(int corePoolSize,
                                                          BlockingQueue<Runnable> queue) {
          return new ThreadPoolExecutor(corePoolSize,
              corePoolSize,
              0,
              TimeUnit.MILLISECONDS,
              queue);
      }
docs: 固定大小线程池，自定义队列
  
  @param corePoolSize 初始化线程池
  @param queue        线程池队列
  @return the thread pool executor