執行緒技術在Java整個技術體系中佔據著非常重要的位置，併發環境是非常複雜的，什麼情況都有可能發生，Java給我們提供了執行緒排程以及同步等機制來保證多執行緒環境下我們的程式碼依然可以正確執行，下面是多個執行緒處理大量資料的簡單實現，入門級

import java.util.ArrayList;

import java.util.List;

/**
 * 多執行緒處理大量資料
 * Title: LargDataWithRunnable.java
 * Copyright: Copyright (c) 2007
 * Company: LTGames
 * @author author
 * @date 2017年4月18日 下午10:17:19
 * @version 1.0
 */
public class LargDataWithRunnable implements Runnable {

  private static int threadCount = 4;//初始化執行緒數
  private List<Integer> list;//待處理資料
  private int perCount = 25;//每個執行緒處理的資料量
  private int flag = 1;//這是第幾個執行緒
  private int count = 123;//待處理資料總數量
  private int havedCount = 0;//已經處理的資料量
 
  //準備資料
  public void data(){
    list = new ArrayList<Integer>();
    for(int i=0; i<count; i++){
      list.add(i);
    }
  }
 
  public void run() {
    List<Integer> sublist = null;
    while(count - havedCount > 0){//執行緒會迴圈執行，直到所有資料都處理完

      synchronized(this){//在分包時需要執行緒同步，避免執行緒間處理重複的資料

   if(count-havedCount != 0) {

                sublist = list.subList(perCount*(flag-1), count - havedCount > perCount ? perCount*flag : perCount*(flag-1) + (count - havedCount));
        flag = flag+1;

        havedCount = sublist.size() + havedCount;

            }

      }

if(sublist != null) {

          for(int j=0; j<sublist.size(); j++){
        System.out.println(Thread.currentThread().getName() + ":" + sublist.get(j));//此處為資料處理（簡單列印 ）

      }

        }

    }
  }
 
  public static void main(String[] args){
    LargDataWithRunnable l = new LargDataWithRunnable();
    l.data();
    for(int i=0; i<threadCount; i++){
      Thread t = new Thread(l);
      t.start();
    }
  }
}