怎樣進行Java線程池管理及分布式Hadoop調度框架搭建

怎樣進行Java線程池管理及分布式Hadoop調度框架搭建 ，針對這個問題，這篇文章詳細介紹了相對應的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

Java線程池管理及分布式Hadoop調度框架搭建。
平時的開發中線程是個少不了的東西，比如tomcat里的servlet就是線程，沒有線程我們如何提供多用戶訪問呢？不過很多剛開始接觸線程的開發工程師卻在這個上面吃了不少苦頭。怎么做一套簡便的線程開發模式框架讓大家從單線程開發快速轉入多線程開發，這確實是個比較難搞的工程。
那具體什么是線程呢？首先看看進程是什么，進程就是系統中執行的一個程序，這個程序可以使用內存、處理器、文件系統等相關資源。例如QQ軟件、Eclipse、Tomcat等就是一個exe程序，運行啟動起來就是一個進程。為什么需要多線程？如果每個進程都是單獨處理一件事情不能多個任務同時處理，比如我們打開qq只能和一個人聊天，我們用eclipse開發代碼的時候不能編譯代碼，我們請求tomcat服務時只能服務一個用戶請求，那我想我們還在原始社會。多線程的目的就是讓一個進程能夠同時處理多件事情或者請求。比如現在我們使用的QQ軟件可以同時和多個人聊天，我們用eclipse開發代碼時還可以編譯代碼，tomcat可以同時服務多個用戶請求。
線程這么多好處，怎么把單進程程序變成多線程程序呢？不同的語言有不同的實現，這里說下java語言的實現多線程的兩種方式：擴展java.lang.Thread類、實現java.lang.Runnable接口。
先看個例子，假設有100個數據需要分發并且計算。看下單線程的處理速度：

1.     package thread;  
   

2.       
   

3.     import java.util.Vector;  
   

4.       
   

5.     public class OneMain {  
   

6.            public static void main(String[] args) throws InterruptedException {  
   

7.                 Vector<Integer> list = new Vector<Integer>(100);  
   

8.       
   

9.                  for (int i = 0; i < 100; i++) {  
   

10.                       list.add(i);  
    

11.                 }  
    

12.       
    

13.                  long start = System.currentTimeMillis();  
    

14.                  while (list.size() > 0) {  
    

15.                        int val = list.remove(0);  
    

16.                       Thread. sleep(100);//模擬處理  
    

17.                       System. out.println(val);  
    

18.                 }  
    

19.                  long end = System.currentTimeMillis();  
    

20.       
    

21.                 System. out.println("消耗 " + (end - start) + " ms");  
    

22.       
    

23.           }  
    

24.       
    

25.            // 消耗 10063 ms  
    

26.     }  
    

27. 
    

28. 再看一下多線程的處理速度，采用了10個線程分別處理：
    

29. 
    

30. [java] view plaincopy在CODE上查看代碼片派生到我的代碼片
    

31. 
    

32.     package thread;  
    

33.       
    

34.     import java.util.Vector;  
    

35.     import java.util.concurrent.CountDownLatch;  
    

36.       
    

37.     public class MultiThread extends Thread {  
    

38.          static Vector<Integer> list = new Vector<Integer>(100);  
    

39.          static CountDownLatch count = new CountDownLatch(10);  
    

40.       
    

41.          public void run() {  
    

42.       
    

43.               while (list.size() > 0) {  
    

44.                    try {  
    

45.                         int val = list.remove(0);  
    

46.                         System.out.println(val);  
    

47.                         Thread.sleep(100);//模擬處理  
    

48.                    } catch (Exception e) {  
    

49.                         // 可能數組越界，這個地方只是為了說明問題，忽略錯誤  
    

50.                    }  
    

51.       
    

52.               }  
    

53.                
    

54.               count.countDown(); // 刪除成功減一  
    

55.       
    

56.          }  
    

57.       
    

58.          public static void main(String[] args) throws InterruptedException {  
    

59.                
    

60.               for (int i = 0; i < 100; i++) {  
    

61.                    list.add(i);  
    

62.               }  
    

63.                
    

64.               long start = System.currentTimeMillis();  
    

65.       
    

66.               for (int i = 0; i < 10; i++) {  
    

67.                    new MultiThread().start();  
    

68.               }  
    

69.       
    

70.                
    

71.       
    

72.               count.await();  
    

73.               long end = System.currentTimeMillis();  
    

74.               System.out.println("消耗 " + (end - start) + " ms");  
    

75.       
    

76.          }  
    

77.       
    

78.          // 消耗 1001 ms  
    

79.     }  

復制代碼

大家看到了線程的好處了吧！單線程需要10S，10個線程只需要1S。充分利用了系統資源實現并行計算。也許這里會產生一個誤解，是不是增加的線程個數越多效率越高。線程越多處理性能越高這個是錯誤的，范式都要合適，過了就不好了。需要普及一下計算機硬件的一些知識。我們的cpu是個運算器，線程執行就需要這個運算器來運行。不過這個資源只有一個，大家就會爭搶。一般通過以下幾種算法實現爭搶cpu的調度：

• 隊列方式，先來先服務。不管是什么任務來了都要按照隊列排隊先來后到。

• 時間片輪轉，這也是最古老的cpu調度算法。設定一個時間片，每個任務使用cpu的時間不能超過這個時間。如果超過了這個時間就把任務暫停保存狀態，放到隊列尾部繼續等待執行。

• 優先級方式：給任務設定優先級，有優先級的先執行，沒有優先級的就等待執行。
  

這三種算法都有優缺點，實際操作系統是結合多種算法，保證優先級的能夠先處理，但是也不能一直處理優先級的任務。硬件方面為了提高效率也有多核cpu、多線程cpu等解決方案。目前看得出來線程增多了會帶來cpu調度的負載增加，cpu需要調度大量的線程，包括創建線程、銷毀線程、線程是否需要換出cpu、是否需要分配到cpu。這些都是需要消耗系統資源的，由此，我們需要一個機制來統一管理這一堆線程資源。線程池的理念提出解決了頻繁創建、銷毀線程的代價。線程池指預先創建好一定大小的線程等待隨時服務用戶的任務處理，不必等到用戶需要的時候再去創建。特別是在java開發中，盡量減少垃圾回收機制的消耗就要減少對象的頻繁創建和銷毀。
之前我們都是自己實現的線程池，不過隨之jdk1.5的推出，jdk自帶了java.util.concurrent并發開發框架，解決了我們大部分線程池框架的重復工作。可以使用Executors來建立線程池，列出以下大概的，后面再介紹。

• newCachedThreadPool建立具有緩存功能線程池

• newFixedThreadPool建立固定數量的線程

• newScheduledThreadPool建立具有時間調度的線程
  

有了線程池后有以下幾個問題需要考慮：

• 線程怎么管理，比如新建任務線程。

• 線程如何停止、啟動。

• 線程除了scheduled模式的間隔時間定時外能否實現精確時間啟動。比如晚上1點啟動。

• 線程如何監控，如果線程執行過程中死掉了，異常終止我們怎么知道。
  

考慮到這幾點，我們需要把線程集中管理起來，用java.util.concurrent是做不到的。需要做以下幾點：

• 將線程和業務分離，業務的配置單獨做成一個表。

• 構建基于concurrent的線程調度框架，包括可以管理線程的狀態、停止線程的接口、線程存活心跳機制、線程異常日志記錄模塊。

• 構建靈活的timer組件，添加quartz定時組件實現精準定時系統。

• 和業務配置信息結合構建線程池任務調度系統。可以通過配置管理、添加線程任務、監控、定時、管理等操作。
  

組件圖為：



構建好線程調度框架是不是就可以應對大量計算的需求了呢?答案是否定的。因為一個機器的資源是有限的，上面也提到了cpu是時間周期的，任務一多了也會排隊，就算增加cpu，一個機器能承載的cpu也是有限的。所以需要把整個線程池框架做成分布式的任務調度框架才能應對橫向擴展，比如一個機器上的資源達到瓶頸了，馬上增加一臺機器部署調度框架和業務就可以增加計算能力了。好了，如何搭建？如下圖：

基本前面的分布式調度框架組件不變，增加如下組件和功能：

• 改造分布式調度框架，可以把本身線程任務變成mapreduce任務并提交到hadoop集群。

• hadoop集群能夠調用業務接口的spring、ibatis處理業務邏輯訪問數據庫。

• hadoop需要的數據能夠通過hive查詢。

• hadoop可以訪問hdfs/hbase讀寫操作。

• 業務數據要及時加入hive倉庫。

• hive處理離線型數據、hbase處理經常更新的數據、hdfs是hive和hbase的底層結構也可以存放常規文件。
  

這樣，整個改造基本完成。不過需要注意的是架構設計一定要減少開發程序的復雜度。這里雖然引入了hadoop模型，但是框架上開發者還是隱藏的。業務處理類既可以在單機模式下運行也可以在hadoop上運行，并且可以調用spring、ibatis。減少了開發的學習成本，在實戰中慢慢體會就學會了一項新技能。

關于怎樣進行Java線程池管理及分布式Hadoop調度框架搭建 問題的解答就分享到這里了，希望以上內容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關注億速云行業資訊頻道了解更多相關知識。