1 package test; 2 3 import java.util.LinkedList; 4 import java.util.List; 5 import java.util.concurrent.CountDownLatch; 6 7 public class ThreadTest { 8 9 /** 10 * 多线程处理list 11 * 12 * @param data 13 * 数据LinkedList,线程安全 14 * @param threadNum 15 * 线程数 16 * @throws InterruptedException 17 */ 18 public synchronized void handleList(LinkedList<String> data, int threadNum) throws InterruptedException { 19 int length = data.size(); 20 int tl = length % threadNum == 0 ? length / threadNum : (length / threadNum + 1); 21 CountDownLatch latch = new CountDownLatch(100);// 多少协作 22 long a = System.currentTimeMillis(); 23 for (int i = 0; i < threadNum; i++) { 24 int end = (i + 1) * tl; 25 if ((i * tl) <= length) { 26 // 继承thread启动线程 27 // HandleThread thread = new HandleThread("线程[" + (i + 1) +"] ",data, i * tl, end > length ? length : end, latch); 28 // thread.start(); 29 30 // 实现Runnable启动线程 31 RunnableThread thread = new RunnableThread("线程[" + (i + 1) + "] ", data, i * tl, end > length ? length : end, latch); 32 Thread runable = new Thread(thread); 33 runable.start(); 34 } 35 } 36 latch.await();// 等待所有工人完成工作 37 System.out.println("结束*****************************"); 38 long b = System.currentTimeMillis(); 39 System.out.println("时间:" + (b - a) + "毫秒***********************"); 40 } 41 42 // 继承Thread 43 class HandleThread extends Thread { 44 private String threadName; 45 private List<String> data; 46 private int start; 47 private int end; 48 private CountDownLatch latch; 49 50 public HandleThread(String threadName, List<String> data, int start, int end, CountDownLatch latch) { 51 this.threadName = threadName; 52 this.data = data; 53 this.start = start; 54 this.end = end; 55 this.latch = latch; 56 } 57 58 public void run() { 59 // TODO 这里处理数据 60 List<String> l = data.subList(start, end); 61 System.out.println(threadName + "--" + data.size() + "--" + start + "--" + end + "--"); 62 for (int i = 0; i < l.size(); i++) { 63 // 单个线程中的数据 64 System.out.println(l.get(i)); 65 } 66 latch.countDown();// 工人完成工作，计数器减一 67 } 68 } 69 70 // 实现Runnable 71 class RunnableThread implements Runnable { 72 private String threadName; 73 private List<String> data; 74 private int start; 75 private int end; 76 private CountDownLatch latch; 77 78 public RunnableThread(String threadName, List<String> data, int start, int end, CountDownLatch latch) { 79 this.threadName = threadName; 80 this.data = data; 81 this.start = start; 82 this.end = end; 83 this.latch = latch; 84 } 85 86 public void run() { 87 // TODO 这里处理数据 88 List<String> l = data.subList(start, end); 89 System.out.println(threadName + "--" + data.size() + "--" + start + "--" + end + "--"); 90 for (int i = 0; i < l.size(); i++) { 91 // 单个线程中的数据 92 System.out.println(l.get(i)); 93 } 94 latch.countDown();// 工人完成工作，计数器减一 95 } 96 } 97 98 public static void main(String[] args) throws InterruptedException { 99 ThreadTest test = new ThreadTest(); 100 101 // 准备数据 102 LinkedList<String> data = new LinkedList<String>(); 103 for (int i = 0; i < 100; i++) { 104 data.add("item" + " " + i); 105 } 106 test.handleList(data, 100); 107 // System.out.println(ArrayUtils.toString(data)); 108 109 } 110 }