Java【代码分享 10】线程池ThreadPoolExecutor指定线程执行任务（修改线程名称+线程任务指定）

public class ThreadManager {
    private static int corePoolSize = Runtime.getRuntime().availableProcessors();
    private static ThreadFactory namedFactory = new ThreadFactoryBuilder().setNameFormat("ods-%d").build();
    /**
     * corePoolSize用于指定核心线程数量
     * maximumPoolSize指定最大线程数
     * keepAliveTime和TimeUnit指定线程空闲后的最大存活时间
     */
    public static ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize, corePoolSize + 1, 10L, TimeUnit.SECONDS,
            new LinkedBlockingQueue<>(1000), namedFactory, new ThreadPoolExecutor.AbortPolicy());
}

// 获取所有线程
  Set<Thread> threads = Thread.getAllStackTraces().keySet();
  List<String> threadsNameList = threads.stream().map(Thread::getName).collect(Collectors.toList());
  // 修改线程名【可根据任务的某些参数对线程进行重命名】
  if (!threadsNameList.contains("threadName")) {
    Thread.currentThread().setName("threadName");
  }
  // 根据线程名称指定任务
  if (Thread.currentThread().getName().equals("threadName")) {
    // 业务代码
  }