Board logo

標題: Java 食唔盡個CPU ? [打印本頁]
作者: geffon    時間: 2018-12-29 18:15     標題: Java 食唔盡個CPU ?

  1. import java.io.BufferedReader;
  2. import java.io.File;
  3. import java.io.FileReader;
  4. import java.io.IOException;
  5. import java.util.ArrayList;
  6. import java.util.concurrent.ExecutorService;
  7. import java.util.concurrent.Executors;

  9. public class Runner {
  10.     public static void main(String[] args) {

  12.         ExecutorService newCachedThreadPool= Executors.newCachedThreadPool();
  13.         //ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(500);
  14.         ArrayList<String> testlist;
  15.         File file = new File("C:\\test.txt");
  16.         BufferedReader reader = null;

  18.         try {
  19.             reader = new BufferedReader(new FileReader(file));
  20.             String tempString = null;
  21.             Integer line = 0;
  22.             testlist= new ArrayList<String>();
  23.             while ((tempString = reader.readLine()) != null) {
  24.                 portlist.add(tempString);
  25.                 line++;
  26.             }
  27.             reader.close();
  28.             System.out.println(testlist.size());
  29.             for(int i=0;i<testlist.size();i++){
  30.                 final String tmpString = testlist.get(i);
  31.                 newCachedThreadPool.execute(new Runnable() {
  32.                     @Override
  33.                     public void run() {
  34.                         try {
  35.                             TestProgram a = new TestProgram();
  36.                             a.start(tmpString);
  37.                         } catch (InterruptedException e) {
  38.                             System.out.println("exception");
  39.                         } catch (Exception e) {
  40.                             e.printStackTrace();
  41.                         }
  42.                     }
  43.                 });
  44.             }
  45.         } catch (IOException e) {
  46.             e.printStackTrace();
  47.         } finally {
  48.             if (reader != null) {
  49.                 try {
  50.                     reader.close();
  51.                 } catch (IOException e1) {
  52.                     e1.printStackTrace();
  53.                 }
  54.             }
  55.         }
  56.     }
  57. }
複製代碼
無論用newFixedThreadPool 定 newCachedThreadPool，CPU使用率都係幾%，點解決？
似乎好似剩係用左單核咁樣樣，code 中 test.txt 為600行，即New 左TestProgram Class六百個同時執行，都係冇乜CPU使用率
作者: vichui    時間: 2018-12-29 18:25

你個TestProgram 行咩先?
行唔行得盡睇你Coding 食幾多resource..

無論用newFixedThreadPool 定 newCachedThreadPool，CPU使用率都係幾%，點解決？
似乎好似剩係用左單核咁樣 ...
geffon 發表於 2018-12-29 18:15
作者: geffon    時間: 2018-12-29 18:33

你個TestProgram 行咩先?
行唔行得盡睇你Coding 食幾多resource..
vichui 發表於 2018-12-29 18:25


行HTTPClient 大量 GET POST
同時行６００—１０００個
newFixedThreadPool　無論教幾多　都係卡下卡下
newCachedThreadPool　都卡下卡下
作者: rabbit82047    時間: 2018-12-29 19:55

http get/post 大部份時間係等資料
作者: vichui    時間: 2018-12-29 20:42

咁呢個係network唔夠快，唔關CPU事， network 可以係自己， 可以係Internet...

http get/post 大部份時間係等資料
rabbit82047 發表於 2018-12-29 19:55
作者: masseffect    時間: 2018-12-29 20:58

咁呢個係network唔夠快，唔關CPU事， network 可以係自己， 可以係Internet...
vichui 發表於 2018-12-29 20:42


重點係，成個PROGRAM係IO INTENSIVE，所以根本唔會用到好快嘅CPU
就算你個NETWORK 快到好似HDD，甚至SSD咁快，一樣唔會用到好多CPU
作者: java2    時間: 2018-12-30 01:26

一睇你catch io exception 就知唔係 cpu intensive process, 食得幾多cpu  
你想食cpu 咪寫d cpu intensive process, 例如做挖礦果d sha256  hash運算囉

無論用newFixedThreadPool 定 newCachedThreadPool，CPU使用率都係幾%，點解決？
似乎好似剩係用左單核咁樣 ...
geffon 發表於 2018-12-29 18:15
作者: yanjar    時間: 2018-12-30 21:28

我都寫過類似 program, 但network通常係bottleneck (用屋企個100Mb/s)
其實java multithreading係用得盡 CPU 的
作者: YuiNarusawa    時間: 2018-12-30 22:13

Java用thread pool開600條thread 真係玩自己, 建議用Java NIO或Node.js呢d event driven既方法
作者: hihihi123hk    時間: 2018-12-31 11:54

行HTTPClient 大量 GET POST
同時行６００—１０００個
newFixedThreadPool　無論教幾多　都係卡下卡下
n ...
geffon 發表於 2018-12-29 18:33


    自己開 VisualVM 睇啦  

用JVM 其中一大原因係因為 Debugging tool 發展得好

via HKEPC IR Pro 3.4.0 - iOS(2.3.3)
作者: rmhc    時間: 2019-1-1 00:21

提示: 作者被禁止或刪除 內容自動屏蔽
作者: ffchung    時間: 2019-1-28 10:05

你  TestProgram 裡面行緊 synchronized function ? 如果係，行幾多thread 都係要排隊.




歡迎光臨 電腦領域 HKEPC Hardware (https://h0.hkepc.com/forum/) Powered by Discuz! 7.2