最近項(xiàng)目上有個(gè)需求，需要從FTP服務(wù)器中下載大批量的數(shù)據(jù)文件，然后解析該數(shù)據(jù)文件進(jìn)行入庫(kù)，數(shù)據(jù)庫(kù)為oracle，最后在通過web工程，以報(bào)表和圖表的形式進(jìn)行展現(xiàn)。

這些批量的數(shù)據(jù)文件為純文本文件，每天產(chǎn)生數(shù)據(jù)文件大概有1500個(gè)，每個(gè)文件大概有500KB，且隨著時(shí)間的推移這些數(shù)據(jù)文件會(huì)逐漸增多。

之前的實(shí)現(xiàn)方式是，通過每天按時(shí)觸發(fā)，建立一個(gè)FTP連接，使用這個(gè)連接讀取文件，讀取一個(gè)下載一個(gè)。部署到生成環(huán)境后，測(cè)試發(fā)現(xiàn)全部完成后，需要7個(gè)小時(shí)，如果文件隨時(shí)間的增長(zhǎng)，顯然是不能接受的。

因此，這里需要改成多線程來處理，這樣就可以縮短讀取的時(shí)間，這里做了個(gè)案例，用來套用到修改的程序中，案例代碼如下：

實(shí)現(xiàn)代碼：package?com.what21.thpool;

import?java.util.concurrent.ArrayBlockingQueue;

import?java.util.concurrent.BlockingQueue;

import?java.util.concurrent.ThreadPoolExecutor;

import?java.util.concurrent.TimeUnit;

import?java.util.concurrent.ThreadPoolExecutor.AbortPolicy;

public?class?ThreadPoolMain?{

/**

*?@param?args

*/

public?static?void?main(String[]?args)?{

//線程池維護(hù)線程的最少數(shù)量

int?corePoolSize?=?50;

//線程池維護(hù)線程的最大數(shù)量

int?maximumPoolSize?=?Integer.MAX_VALUE;

//線程池維護(hù)線程所允許的空閑時(shí)間

long?keepAliveTime?=?4;

//線程池維護(hù)線程所允許的空閑時(shí)間的單位

TimeUnit?unit?=?TimeUnit.SECONDS;

BlockingQueue?taskQueue?=?new?ArrayBlockingQueue(10);

//?AbortPolicy?策略

//?處理程序遭到拒絕將拋出運(yùn)行時(shí)RejectedExecutionException

AbortPolicy?handler?=?new?ThreadPoolExecutor.AbortPolicy();

//?初始化線程池

ThreadPoolExecutor?threadPool?=?new?ThreadPoolExecutor(corePoolSize,?maximumPoolSize,

keepAliveTime,?unit,?taskQueue,?handler);

//?線程池執(zhí)行

for(int?i=0;i<1000;i++){

final?int?count?=?i;

threadPool.execute(new?Thread(new?Runnable(){

@Override

public?void?run()?{

try?{

Thread.sleep(1*1000);

}?catch?(InterruptedException?e)?{

e.printStackTrace();

}

System.out.println(count);

}

}));

}

}

}

執(zhí)行流程描述：

1、線程池threadPool初始化時(shí)，任務(wù)隊(duì)列taskQueue中的線程為空，線程池是不會(huì)馬上執(zhí)行的。

2、當(dāng)調(diào)用 線程池threadPool的execute()方法時(shí)，添加一個(gè)線程，線程池會(huì)做出如下的判斷：

a、如果當(dāng)前正在運(yùn)行的線程數(shù)量小于corePoolSize，就立即創(chuàng)建并執(zhí)行這個(gè)線程；

b、如果當(dāng)前正在運(yùn)行的線程數(shù)量大于或等于corePoolSize，新添加的線程會(huì)放入隊(duì)列；

c、如果隊(duì)列滿了，正在運(yùn)行的線程數(shù)量小于 maximumPoolSize，就繼續(xù)創(chuàng)建線程運(yùn)行這個(gè)任務(wù)；

d、如果隊(duì)列滿了，正在運(yùn)行的線程數(shù)量大于或等于 maximumPoolSize，線程池threadPool會(huì)拋出不能接受新任務(wù)的異常。

3、當(dāng)一個(gè)線程完成任務(wù)時(shí)，它會(huì)從隊(duì)列taskQueue中取出一個(gè)任務(wù)來進(jìn)行執(zhí)行。

4、當(dāng)一個(gè)線程執(zhí)行完畢時(shí)，超過一定的時(shí)間keepAliveTime時(shí)，線程池threadPool會(huì)判斷，如果當(dāng)前池中運(yùn)行的線程數(shù)大于corePoolSize，那么這個(gè)線程就被停掉。線程池threadPool的所有任務(wù)完成后，它最終會(huì)收縮到corePoolSize的大小。

通過使用上述原理的多線程功能實(shí)現(xiàn)，且每次都有50個(gè)線程并發(fā)執(zhí)行，測(cè)試后，發(fā)現(xiàn)大大的降低了執(zhí)行時(shí)間，變成了2個(gè)多小時(shí)，實(shí)踐證明多線程就是好！！！

總結(jié)

以上是生活随笔為你收集整理的java 多线程池_Java ThreadPoolExecutor线程池 同时执行50个线程的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。