JDK8線程池/線程執行高負載方法


import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

  public void xxMethod() {   
// 創建線程池   ExecutorService threadPool = Executors.newFixedThreadPool(list.size());   // 開啟線程/循環執行   for (Object object: list) {   String xxx = object.getXxx();   String yyy = object.getYyy();   threadPool.submit(new XxClass(xxx , yyy));   }

  }
/** * 線程內部類 */ class XxClass implements Runnable { private String xxx; private String yyy; public XxClass (String xxx, String yyy) { this.xxx= xxx; this.yyy= yyy; } @Override public void run() { xxMethod(xxx, yyy); }

   }

線程池大小根據業務需求調整

如需返回值可實現Callable接口


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM