多線程處理list

package test;

import java.util.LinkedList;
import java.util.List;
import java.util.concurrent.CountDownLatch;

public class ThreadTest {

    /**
     * 多線程處理list
     * 
     * @param data
     *            數據LinkedList,線程安全
     * @param threadNum
     *            線程數
     * @throws InterruptedException
     */
    public synchronized void handleList(LinkedList<String> data, int threadNum) throws InterruptedException {
        int length = data.size();
        int tl = length % threadNum == 0 ? length / threadNum : (length / threadNum + 1);
        CountDownLatch latch = new CountDownLatch(100);// 多少協作
        long a = System.currentTimeMillis();
        for (int i = 0; i < threadNum; i++) {
            int end = (i + 1) * tl;
            if ((i * tl) <= length) {
                // 繼承thread啟動線程
                // HandleThread thread = new HandleThread("線程[" + (i + 1) +"] ",data, i * tl, end > length ? length : end, latch);
                // thread.start();

                // 實現Runnable啟動線程
                RunnableThread thread = new RunnableThread("線程[" + (i + 1) + "] ", data, i * tl, end > length ? length : end, latch);
                Thread runable = new Thread(thread);
                runable.start();
            }
        }
        latch.await();// 等待所有工人完成工作
        System.out.println("結束*****************************");
        long b = System.currentTimeMillis();
        System.out.println("時間:" + (b - a) + "毫秒***********************");
    }

    // 繼承Thread
    class HandleThread extends Thread {
        private String threadName;
        private List<String> data;
        private int start;
        private int end;
        private CountDownLatch latch;

        public HandleThread(String threadName, List<String> data, int start, int end, CountDownLatch latch) {
            this.threadName = threadName;
            this.data = data;
            this.start = start;
            this.end = end;
            this.latch = latch;
        }

        public void run() {
            // TODO 這里處理數據
            List<String> l = data.subList(start, end);
            System.out.println(threadName + "--" + data.size() + "--" + start + "--" + end + "--");
            for (int i = 0; i < l.size(); i++) {
                // 單個線程中的數據
                System.out.println(l.get(i));
            }
            latch.countDown();// 工人完成工作，計數器減一
        }
    }

    // 實現Runnable
    class RunnableThread implements Runnable {
        private String threadName;
        private List<String> data;
        private int start;
        private int end;
        private CountDownLatch latch;

        public RunnableThread(String threadName, List<String> data, int start, int end, CountDownLatch latch) {
            this.threadName = threadName;
            this.data = data;
            this.start = start;
            this.end = end;
            this.latch = latch;
        }

        public void run() {
            // TODO 這里處理數據
            List<String> l = data.subList(start, end);
            System.out.println(threadName + "--" + data.size() + "--" + start + "--" + end + "--");
            for (int i = 0; i < l.size(); i++) {
                // 單個線程中的數據
                System.out.println(l.get(i));
            }
            latch.countDown();// 工人完成工作，計數器減一
        }
    }

    public static void main(String[] args) throws InterruptedException {
        ThreadTest test = new ThreadTest();

        // 准備數據
        LinkedList<String> data = new LinkedList<String>();
        for (int i = 0; i < 100; i++) {
            data.add("item" + "  " + i);
        }
        test.handleList(data, 100);
        // System.out.println(ArrayUtils.toString(data));

    }
}