Java 食唔盡個CPU ?

geffon

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;
   
8. 
   
9. public class Runner {
   
10.     public static void main(String[] args) {
    
11. 
    
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;
    
17. 
    
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

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

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

geffon

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

行HTTPClient 大量 GET POST
同時行６００—１０００個
newFixedThreadPool　無論教幾多　都係卡下卡下
newCachedThreadPool　都卡下卡下

rabbit82047

http get/post 大部份時間係等資料

vichui

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

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

masseffect

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

重點係，成個PROGRAM係IO INTENSIVE，所以根本唔會用到好快嘅CPU
就算你個NETWORK 快到好似HDD，甚至SSD咁快，一樣唔會用到好多CPU

java2

一睇你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

我都寫過類似 program, 但network通常係bottleneck (用屋企個100Mb/s)
其實java multithreading係用得盡 CPU 的

YuiNarusawa

Java用thread pool開600條thread 真係玩自己, 建議用Java NIO或Node.js呢d event driven既方法

hihihi123hk

行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)