怎么在java中利用多線程對(duì)數(shù)據(jù)進(jìn)行分頁(yè)處理

這篇文章將為大家詳細(xì)講解有關(guān)怎么在java中利用多線程對(duì)數(shù)據(jù)進(jìn)行分頁(yè)處理，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個(gè)參考，希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。

1.常見的分頁(yè)類型

傳統(tǒng)的：采用傳統(tǒng)的分頁(yè)方式，可以明確的獲取數(shù)據(jù)信息，如有多少條數(shù)據(jù)，分多少頁(yè)顯示等。

下拉式：采用下拉式的分頁(yè)方式，一般無(wú)法獲取明確的數(shù)據(jù)數(shù)量相關(guān)的信息，但在分頁(yè)操作以后，仍然可以看到之前查詢的數(shù)據(jù)。

2.分頁(yè)式查詢邏輯

int pageSize = 100;
int currentPageLength = 0;
int pageIndex = 0;
ExecutorService exe = newFixedThreadPool(Runtime.getRuntime().availableProcessors());
do {
  int offset = pageIndex * pageSize;
  List<TradeInfo> tradeInfos = tradeInfoService.findTradeInfoBysPage(queryParams,offset,pageSize);
  if (null != tradeInfos && tradeInfos.size() > 0) {
    currentPageLength = tradeInfos.size();
    TradeInfoProcesserTask task = new TradeInfoProcesserTask(tradeInfos );
    exe.execute(task);
    pageIndex++;
  }else{
    System.out.println("Page Query TradeInfo Got NOTHING! Break query loop!");
    break;
  }
} while (currentPageLength == pageSize);
exe.shutdown();
while(true) {
  if(exe.isTerminated()){
    doOtherThings();
    System.out.println("分頁(yè)式多線程處理數(shù)據(jù)完畢！");
    break;
  }
}

3.數(shù)據(jù)處理邏輯

public class TradeInfoProcesserTask implements Runnable{
  private volatile List<TradeInfo> tradeInfos;
   
  public TradeInfoProcesserTask (List<TradeInfo> _tradeInfos){
    tradeInfos = _tradeInfos;
  }
   
  @Override
  public void run() {
    processTradeInfos();
  }
   
  private void processTradeInfos(){
    //do something with tradeInfos .....
  }
}

關(guān)于怎么在java中利用多線程對(duì)數(shù)據(jù)進(jìn)行分頁(yè)處理就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。