Java多线程处理大量数据

线程技术在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();
    }
  }
}