典型Java線程池的代碼及其各部分功能介紹

（ ）根據xml文件來管理線程池的最大最小線程數（ ）對線程池通過Timer定期掃描以防止線程未激活 （ ）通過某一個變量（本程序中是freeThreadCount）來得到空閑線程的數目 一 配置xml（listen xml）是 ?xml version= encoding= UTF ?configConsumeThreadPoolminPools /minPools　! 線程池最小線程 maxPools /maxPools! 線程池最大線程 checkThreadPeriod /checkThreadPeriod　! 檢查線程池中線程的周期 分鐘 /ConsumeThreadPool/config 二 對于ConsumeThreadPoolPara的javabean: import java io *;public class ConsumeThreadPoolPara implements Serializable{private int minPools;private int maxPools;private int checkThreadPeriod;public int getMinPools(){return minPools;}public int getMaxPools(){return maxPools;}public int getCheckThreadPeriod(){return checkThreadPeriod;}public void setMinPools(int minPools){this minPools = minPools;}public void setMaxPools(int maxPools){this maxPools = maxPools;}public void setCheckThreadPeriod(int checkThreadPeriod){this checkThreadPeriod = checkThreadPeriod;}public String toString(){return minPools+ + maxPools+ +checkThreadPeriod;}public ConsumeThreadPoolPara() {}public static void main(String[] args) {ConsumeThreadPoolPara consumeThreadPool = new ConsumeThreadPoolPara();}} 三 解析xml程序代碼（生成ConsumeThreadPoolPara） 使用jdom解析 import jdom *;import jdom input SAXBuilder;import java io *;import java util *;public class ParseConfig {static Hashtable Listens = null;static ConnPara connpara = null;static ConsumeThreadPoolPara consumeThreadPoolPara = null;private static String configxml = listen xml ;static{getConsumeThreadPoolPara();　//得到消費的線程池的參數}/*** 裝載文檔* @return 返回根結點* @throws JDOMException*/public static Element loadDocument() throws JDOMException{SAXBuilder parser = new SAXBuilder(); // 新建立構造器try {Document document = parser build(configxml);Element root = document getRootElement();return root;}catch(JDOMException e){logger error( listen xml文件格式非法！ );throw new JDOMException();}}public static ConsumeThreadPoolPara getConsumeThreadPoolPara(){if(consumeThreadPoolPara ==null){try {Element root = loadDocument();Element consumeThreadPool = root getChild( ConsumeThreadPool );if (consumeThreadPool != null) { //代表有數據庫配置consumeThreadPoolPara = new ConsumeThreadPoolPara();Element minPools = consumeThreadPool getChild( minPools );consumeThreadPoolPara setMinPools(Integer parseInt(minPools getTextTrim()));Element maxPools = consumeThreadPool getChild( maxPools );consumeThreadPoolPara setMaxPools(Integer parseInt(maxPools getTextTrim()));Element checkThreadPeriod = consumeThreadPool getChild( checkThreadPeriod );consumeThreadPoolPara setCheckThreadPeriod(Integer parseInt(checkThreadPeriod getTextTrim()));}}catch (JDOMException e) {}}return consumeThreadPoolPara;}} 四 線程池源代碼 import java util *;/*** pTitle: 線程池/p* pDescription: 采集消費模塊/p* pCopyright: Copyright (c) /p* pCompany: /p* @author 張榮斌* @version */public class ThreadPool {private static int minPools = ; //最小連接池數目private static int maxPools = ; //最大連接池數目private static int checkThreadPeriod = ; //檢查連接池的周期ArrayList m_ThreadList;　//工作線程列表LinkedList m_RunList = null;　//工作任務列表int totalThread = ;　//總線程數static int freeThreadCount = ;　//未被使用的線程數目private java util Timer timer = null;　//定時器static Object o = new Object();static{　//先初始化線程池的參數ConsumeThreadPoolPara consumeThreadPoolPara = ParseConfig getConsumeThreadPoolPara();if(consumeThreadPoolPara!=null){minPools = consumeThreadPoolPara getMinPools();maxPools = consumeThreadPoolPara getMaxPools();checkThreadPeriod = consumeThreadPoolPara getCheckThreadPeriod()* * ;}}public void setMinPools(int minPools){this minPools = minPools;}public void setMaxPools(int maxPools){this maxPools = maxPools;}public void setCheckThreadPeriod(int checkThreadPeriod){this checkThreadPeriod = checkThreadPeriod;}public ThreadPool() {m_ThreadList=new ArrayList();m_RunList=new LinkedList();for(int i= ;iminPools;i++){WorkerThread temp=new WorkerThread();totalThread = totalThread + ;m_ThreadList add(temp);temp start();try{Thread sleep( );}catch(Exception e){}}timer = new Timer(true);　//啟動定時器timer schedule(new CheckThreadTask(this) checkThreadPeriod);}/*** 當有一個工作來的時候啟動線程池的線程* 當空閑線程數為 的時候 看總線程是否小于最大線程池的數目 就new一個新的線程 否則sleep 直到有空閑線程為止;* 當空閑線程不為 則將任務丟給空閑線程去完成* @param work*/public synchronized void run(String work){if (freeThreadCount == ) {if(totalThreadmaxPools){WorkerThread temp = new WorkerThread();totalThread = totalThread + ;m_ThreadList add(temp);temp start();synchronized(m_RunList){m_RunList add(work);m_RunList notify();}}else{while (freeThreadCount == ) {try {Thread sleep( );}catch (InterruptedException e) {}}synchronized(m_RunList){m_RunList add(work);m_RunList notify();}}} else {synchronized(m_RunList){m_RunList add(work);m_RunList notify();}}}/*** 檢查所有的線程的有效性*/public synchronized void checkAllThreads() {Iterator lThreadIterator = erator();while (lThreadIterator hasNext()) { //逐個遍厲WorkerThread lTestThread = (WorkerThread) lThreadIterator next();if (! (lTestThread isAlive())) { //如果處在非活動狀態時lTestThread = new WorkerThread(); //重新生成個線程lTestThread start(); //啟動}}}/*** 打印調試信息*/public void printDebugInfo(){System out println( totalThread= +totalThread);System out println( m_ThreadList size()= +m_ThreadList size());}/**** pTitle: 工作線程類/p* @author 張榮斌* @version */class WorkerThread extends Thread{boolean running = true;String work;public void run(){while(running){synchronized(o){freeThreadCount++;}synchronized(m_RunList){while(m_RunList size() == ){try{m_RunList wait();if(!running) return;}catch(InterruptedException e){} lishixinzhi/Article/program/Java/gj/201311/27379

創新互聯是專業的犍為網站建設公司，犍為接單;提供網站設計制作、成都做網站,網頁設計,網站設計,建網站,PHP網站建設等專業做網站服務;采用PHP框架,可快速的進行犍為網站開發網頁制作和功能擴展;專業做搜索引擎喜愛的網站,專業的做網站團隊,希望更多企業前來合作!

如何合理地估算Java線程池大小

最簡單的可以利用java.util.concurrent.Executors 調用Executors.newCachedThreadPool()獲取緩沖式線程池 Executors.newFixedThreadPool(int nThreads)獲取固定大小的線程池

怎樣查看JAVA內存的大小？

首先先說一下JVM內存結構問題，JVM為兩塊：PermanentSapce和HeapSpace，其中

Heap = }。PermantSpace負責保存反射對象，一般不用配置。JVM的Heap區可以通過-X參數來設定。

當一個URL被訪問時，內存申請過程如下：

A. JVM會試圖為相關Java對象在Eden中初始化一塊內存區域

B. 當Eden空間足夠時，內存申請結束。否則到下一步

C. JVM試圖釋放在Eden中所有不活躍的對象（這屬于1或更高級的垃圾回收）, 釋放后若Eden空間仍然不足以放入新對象，則試圖將部分Eden中活躍對象放入Survivor區

D. Survivor區被用來作為Eden及OLD的中間交換區域，當OLD區空間足夠時，Survivor區的對象會被移到Old區，否則會被保留在Survivor區

E. 當OLD區空間不夠時，JVM會在OLD區進行完全的垃圾收集（0級）

F. 完全垃圾收集后，若Survivor及OLD區仍然無法存放從Eden復制過來的部分對象，導致JVM無法在Eden區為新對象創建內存區域，則出現”out of memory錯誤”

JVM調優建議:

ms/mx：定義YOUNG+OLD段的總尺寸，ms為JVM啟動時YOUNG+OLD的內存大小；mx為最大可占用的YOUNG+OLD內存大小。在用戶生產環境上一般將這兩個值設為相同，以減少運行期間系統在內存申請上所花的開銷。

NewSize/MaxNewSize：定義YOUNG段的尺寸，NewSize為JVM啟動時YOUNG的內存大小；MaxNewSize為最大可占用的YOUNG內存大小。在用戶生產環境上一般將這兩個值設為相同，以減少運行期間系統在內存申請上所花的開銷。

PermSize/MaxPermSize：定義Perm段的尺寸，PermSize為JVM啟動時Perm的內存大小；MaxPermSize為最大可占用的Perm內存大小。在用戶生產環境上一般將這兩個值設為相同，以減少運行期間系統在內存申請上所花的開銷。

SurvivorRatio：設置Survivor空間和Eden空間的比例

內存溢出的可能性

1. OLD段溢出

這種內存溢出是最常見的情況之一，產生的原因可能是：

1) 設置的內存參數過小(ms/mx, NewSize/MaxNewSize)

2) 程序問題

單個程序持續進行消耗內存的處理，如循環幾千次的字符串處理，對字符串處理應建議使用StringBuffer。此時不會報內存溢出錯，卻會使系統持續垃圾收集，無法處理其它請求，相關問題程序可通過Thread Dump獲取（見系統問題診斷一章）單個程序所申請內存過大，有的程序會申請幾十乃至幾百兆內存，此時JVM也會因無法申請到資源而出現內存溢出，對此首先要找到相關功能，然后交予程序員修改，要找到相關程序，必須在Apache日志中尋找。

當Java對象使用完畢后，其所引用的對象卻沒有銷毀，使得JVM認為他還是活躍的對象而不進行回收，這樣累計占用了大量內存而無法釋放。由于目前市面上還沒有對系統影響小的內存分析工具，故此時只能和程序員一起定位。

2. Perm段溢出

通常由于Perm段裝載了大量的Servlet類而導致溢出，目前的解決辦法：

1) 將PermSize擴大，一般256M能夠滿足要求

2) 若別無選擇，則只能將servlet的路徑加到CLASSPATH中，但一般不建議這么處理

3. C Heap溢出

系統對C Heap沒有限制，故C Heap發生問題時，Java進程所占內存會持續增長，直到占用所有可用系統內存

參數說明:

JVM 堆內存（heap）設置選項

參數格式

說 明

設置新對象生產堆內存（Setting the Newgeneration heap size）

-XX:NewSize

通過這個選項可以設置Java新對象生產堆內存。在通常情況下這個選項的數值為1 024的整數倍并且大于1MB。這個值的取值規則為，一般情況下這個值-XX:NewSize是最大堆內存（maximum heap size）的四分之一。增加這個選項值的大小是為了增大較大數量的短生命周期對象

增加Java新對象生產堆內存相當于增加了處理器的數目。并且可以并行地分配內存，但是請注意內存的垃圾回收卻是不可以并行處理的

設置最大新對象生產堆內存（Setting the maximum New generation heap size）

-XX:MaxNewSize

通過這個選項可以設置最大Java新對象生產堆內存。通常情況下這個選項的數值為1 024的整數倍并且大于1MB

其功用與上面的設置新對象生產堆內存-XX：NewSize相同

設置新對象生產堆內存的比例（Setting New heap size ratios）

-XX:SurvivorRatio

新對象生產區域通常情況下被分為3個子區域：伊甸園，與兩個殘存對象空間，這兩個空間的大小是相同的。通過用-XX:SurvivorRatio=X選項配置伊甸園與殘存對象空間（Eden/survivor）的大小的比例。你可以試著將這個值設置為8，然后監控、觀察垃圾回收的工作情況

設置堆內存池的最大值（Setting maximum heap size）

-Xmx

通過這個選項可以要求系統為堆內存池分配內存空間的最大值。通常情況下這個選項的數值為1 024的整數倍并且大于1 MB

一般情況下這個值（-Xmx）與最小堆內存（minimum heap size –Xms）相同，以降低垃圾回收的頻度

取消垃圾回收

-Xnoclassgc

這個選項用來取消系統對特定類的垃圾回收。它可以防止當這個類的所有引用丟失之后，這個類仍被引用時不會再一次被重新裝載，因此這個選項將增大系統堆內存的空間

設置棧內存的大小

-Xss

這個選項用來控制本地線程棧的大小，當這個選項被設置的較大（2MB）時將會在很大程度上降低系統的性能。因此在設置這個值時應該格外小心，調整后要注意觀察系統的性能，不斷調整以期達到最優

最后說一句，你的機器的連接數設置也至關重要，連接的關閉最好把時間設置的少些，那些連接非常耗費資源。也是引起內存泄露的主要原因。

標題名稱：查看java池的大小代碼 java 查看內存占用
當前地址：http://vcdvsql.cn/article38/dopiipp.html

成都網站建設公司_創新互聯，為您提供關鍵詞優化、網頁設計公司、網站改版、軟件開發、品牌網站建設、外貿網站建設

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯