最近在項(xiàng)目里面使用了多線程處理技術(shù)，感覺(jué)對(duì)數(shù)據(jù)很多批量處理效果蠻好，所以在這里記錄下來(lái)，給自己一個(gè)日子，也分享給大家！

1.首先根據(jù)條件得到你的數(shù)據(jù)集合dataList(此處用dataList表示)

1.1個(gè)人覺(jué)得如果得到的數(shù)據(jù)很少的話，就沒(méi)必要使用多線程了

2.用 int threadNum = Runtime.getRuntime().availableProcessors();得到你的cpu內(nèi)核數(shù)

2.1對(duì)于內(nèi)核數(shù)這個(gè)來(lái)做下自己的說(shuō)明，當(dāng)時(shí)自己在做的時(shí)候，查看了一些對(duì)于使用cpu核數(shù)的文章

有些高手做了一些性能方面的測(cè)試，表示當(dāng)核數(shù)叫多的時(shí)候，處理性能提升很好，但更多的時(shí)候，已經(jīng)沒(méi)有那么明顯的效果了(好像記得那位高手借鑒了IBM的某個(gè)文章來(lái)說(shuō)了的)，這個(gè)大家可以另外去搜索查詢下，個(gè)人是以 4個(gè)為標(biāo)準(zhǔn)來(lái)做的，大家可以自尋決定

3. 根據(jù)dataListSize 與 threadNum，來(lái)計(jì)算每個(gè)線程需要處理的數(shù)據(jù)量

3.1 相關(guān)代碼

int threadListSize = dataListSize;

if(listSize<threadNum)

{

threadNum=1;

}

else if(threadNum>4)

{

threadNum=4;

threadListSize = listSize / threadNum;

}

else

{

threadListSize = listSize / threadNum;

}

final int[] dataRange = new int[threadNum];

for (int i = 0; i < threadNum - 1; i++) {

dataRange[i] = threadListSize * (i + 1);

}

//有些不可能一下子除斷，所以最后一個(gè)dataRange必須包含剩下所有的

dataRange[threadNum - 1] = listSize;

3.2一些說(shuō)明

大家可能問(wèn)我這是要干什么，我來(lái)慢慢說(shuō)明。由于數(shù)據(jù)集合 dataList 只有一個(gè)，但你需要做多線程處理，那怎么辦？根據(jù)cpu內(nèi)核數(shù)(threadNum)把這個(gè)數(shù)據(jù)集合 dataList分成幾個(gè) 數(shù)據(jù)集合？

不行了，性能太差了，直接根據(jù)list的索引來(lái)做啦，比如list.get(0),直接把索引分成對(duì)應(yīng)的幾個(gè)部分，然后dataList直接調(diào)用

4.開(kāi)始多線程啦

4.1 相關(guān)代碼

4.1.1第一部分

ExecutorService executor = Executors.newFixedThreadPool(threadNum);

Future<JSONArray>[] results = new Future[threadNum];

for (int i = 0; i < threadNum; i++) {

int startIndex=0;

if(i!=0)

{

startIndex=dataRange[i-1];

}

results[i]=executor.submit(new CounterTask(startIndex, dataRange[i]));

}

//每個(gè)線程處理完了之后，就會(huì)把對(duì)應(yīng)返回的結(jié)果返回到 Future<JSONArray>[]

JSONArray resultArray=new JSONArray();

for(int i = 0; i < threadNum; i++)

{

resultArray.addAll(results[i].get());

}

//這個(gè)不要忘了

executor.shutdown();

4.1.2 第二部分(這個(gè)可以直接作為內(nèi)部類來(lái)處理，不必外建一個(gè)類)

class CounterTask implements Callable<JSONArray>{

private int startIndex;

private int endIndex;

public CounterTask(int startIndex,int endIndex){

this.startIndex=startIndex;

this.endIndex=endIndex;

}

@Override

public JSONArray call() throws Exception {

// TODO Auto-generated method stub

return MailCall(startIndex,endIndex);

}

}

4.1.3 第三部分代碼

protected JSONArray MailCall(int startIndex,int endIndex) {

JSONArray resultArray=new JSONArray();

JSONObject result=null;

for(int i=startIndex;i<endIndex;i++)

{

Object object=dataList.get(i)

//根據(jù)你的邏輯做自己的事啦

。。。。。

}

return resultArray;

｝

5.雖然結(jié)束了，但還需做一些說(shuō)明

5.1 在 MailCall這個(gè)方法里，由于是多線程，所以這個(gè)里面不能使用非線程安全共享的，比如

simpleDateFormat,關(guān)于這個(gè)怎么去解決，

（1）很多人都是用 apache的commons-lang包的DateUtils和DateFormatUtils類，這兩個(gè)類的方法是線程安全的。

（2）直接在這個(gè)方法里面 new 一個(gè)simpleDateFormat的新對(duì)象(感覺(jué)不好，如果多了不很消耗性能,1000條數(shù)據(jù)不要new 1000個(gè)simpleDateFormat對(duì)象么。。。。。。。)

（3）還有其它的就不說(shuō)了，可自尋搜索啦

更多信息請(qǐng)查看IT技術(shù)專欄