多线程执行方法

0o好好先生o0 / 2024-09-27 / 原文

public void runExecutors(){
  int coreCount = Runtime.getRuntime().availableProcessors();
  int executeCount = 2 * coreCount; // 根据实际情况调整
  ExecutorService executor = Executors.newFixedThreadPool(executeCount);
  for (final xx x : xxx) {
    executor.submit(new Runnable() {//如想获取值同步Future<?> future = executor.submit(new Runnable() {


      @Override
      public void run() {
        执行方法;
      }
    });
  }

  //如想获取值同步 future.get();
  executor.shutdown();
  try {
    executor.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
  } catch (InterruptedException e) {
    e.printStackTrace();
  }
}