list平均分配給多個(gè)線程算法

int num = 20;

ExecutorService service = Executors.newFixedThreadPool(num);

int rows = 3568;

int pageSize = 100;

int pageSum = (rows - 1) / pageSize + 1;

List<Integer> list = new ArrayList<>();

for (int i = 1; i <= pageSum; i++){

list.add(i);

}

int baseNum = pageSum / num;

int remainderNum = pageSum % num;

int end = 0;

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

{

int start = end ;

end = start + baseNum;

if(i == (num-1)){

end = pageSum;

}else if( i < remainderNum){

end = end + 1;

}

int finalEnd = end;

service.submit(

new Runnable() {

@Override

public void run() {

List<Integer> listSmall = list.subList(start, finalEnd? );

try {

for (Integer integer : listSmall)

{

System.out.println(integer);

}

} catch (Exception e) {

e.printStackTrace();

}

}

});

}

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容