• 分割List，根據採用的執行緒(任務)數平均分配，即list.size()/threadCounts。
• 定義一個記錄“很大List”中所有整數和的變數sum，採用一個執行緒(任務)處理一個分割後的子List，計運算元List中所有整數和(subSum)，然後把和(subSum)累加到sum上。
• 等待所有執行緒(任務)完成後輸出總和(sum)的值。

1. /** 
2.  * 計算List中所有整數的和<br> 
3.  * 採用多執行緒，分割List計算 
4.  * @author 飛雪無情 
5.  * @since 2010-7-12
    
6.  */  
7. public class CountListIntegerSum {  
8.     private long sum;//存放整數的和  
9.     private CyclicBarrier barrier;//障柵集合點(同步器)  
10.     private List<Integer> list;//整數集合List  
11.     private int threadCounts;//使用的執行緒數  
12.     public CountListIntegerSum(List<Integer> list,int threadCounts) {  
13.         this.list=list;  
14.         this.threadCounts=threadCounts;  
15.     }  
16.     /** 
17.      * 獲取List中所有整數的和 
18.      * @return 
19.      */  
20.     public long getIntegerSum(){  
21.         ExecutorService exec=Executors.newFixedThreadPool(threadCounts);  
22.         int len=list.size()/threadCounts;//平均分割List  
23.         //List中的數量沒有執行緒數多（很少存在）  
24.         if(len==0){  
25.             threadCounts=list.size();//採用一個執行緒處理List中的一個元素  
26.             len=list.size()/threadCounts;//重新平均分割List  
27.         }  
28.         barrier=new CyclicBarrier(threadCounts+1);  
29.         for(int i=0;i<threadCounts;i++){  
30.             //建立執行緒任務  
31.             if(i==threadCounts-1){//最後一個執行緒承擔剩下的所有元素的計算  
32.                 exec.execute(new SubIntegerSumTask(list.subList(i*len,list.size())));  
33.             }else{  
34.                 exec.execute(new SubIntegerSumTask(list.subList(i*len, len*(i+1)>list.size()?list.size():len*(i+1))));  
35.             }  
36.         }  
37.         try {  
38.             barrier.await();//關鍵，使該執行緒在障柵處等待，直到所有的執行緒都到達障柵處  
39.         } catch (InterruptedException e) {  
40.             System.out.println(Thread.currentThread().getName()+":Interrupted");  
41.         } catch (BrokenBarrierException e) {  
42.             System.out.println(Thread.currentThread().getName()+":BrokenBarrier");  
43.         }  
44.         exec.shutdown();  
45.         return sum;  
46.     }  
47.     /** 
48.      * 分割計算List整數和的執行緒任務 
49.      * @author lishuai 
50.      * 
51.      */  
52.     public class SubIntegerSumTask implements Runnable{  
53.         private List<Integer> subList;  
54.         public SubIntegerSumTask(List<Integer> subList) {  
55.             this.subList=subList;  
56.         }  
57.         public void run() {  
58.             long subSum=0L;  
59.             for (Integer i : subList) {  
60.                 subSum += i;  
61.             }    
62.             synchronized(CountListIntegerSum.this){//在CountListIntegerSum物件上同步  
63.                 sum+=subSum;  
64.             }  
65.             try {  
66.                 barrier.await();//關鍵，使該執行緒在障柵處等待，直到所有的執行緒都到達障柵處  
67.             } catch (InterruptedException e) {  
68.                 System.out.println(Thread.currentThread().getName()+":Interrupted");  
69.             } catch (BrokenBarrierException e) {  
70.                 System.out.println(Thread.currentThread().getName()+":BrokenBarrier");  
71.             }  
72.             System.out.println("分配給執行緒："+Thread.currentThread().getName()+"那一部分List的整數和為：\tSubSum:"+subSum);  
73.         }  
74.     }  
75. }  

1. /** 
2.  * 計算List中所有整數的和測試類 
3.  * @author 飛雪無情 
4.  * @since 2010-7-12 
5.  */  
6. public class CountListIntegerSumMain {  
7.     /** 
8.      * @param args 
9.      */  
10.     public static void main(String[] args) {  
11.         List<Integer> list = new ArrayList<Integer>();  
12.         int threadCounts = 10;//採用的執行緒數  
13.         //生成的List資料  
14.         for (int i = 1; i <= 1000000; i++) {  
15.             list.add(i);  
16.         }  
17.         CountListIntegerSum countListIntegerSum=new CountListIntegerSum(list,threadCounts);  
18.         long sum=countListIntegerSum.getIntegerSum();  
19.         System.out.println("List中所有整數的和為:"+sum);  
20.     }  
21. }  

1. /** 
2.  * 使用ExecutorService的invokeAll方法計算 
3.  * @author 飛雪無情 
4.  * 
5.  */  
6. public class CountSumWithCallable {  
7.     /** 
8.      * @param args 
9.      * @throws InterruptedException  
10.      * @throws ExecutionException  
11.      */  
12.     public static void main(String[] args) throws InterruptedException, ExecutionException {  
13.         int threadCounts =19;//使用的執行緒數  
14.         long sum=0;  
15.         ExecutorService exec=Executors.newFixedThreadPool(threadCounts);  
16.         List<Callable<Long>> callList=new ArrayList<Callable<Long>>();  
17.         //生成很大的List  
18.         List<Integer> list = new ArrayList<Integer>();  
19.         for (int i = 0; i <= 1000000; i++) {  
20.             list.add(i);  
21.         }  
22.         int len=list.size()/threadCounts;//平均分割List  
23.         //List中的數量沒有執行緒數多（很少存在）  
24.         if(len==0){  
25.             threadCounts=list.size();//採用一個執行緒處理List中的一個元素  
26.             len=list.size()/threadCounts;//重新平均分割List  
27.         }  
28.         for(int i=0;i<threadCounts;i++){  
29.             final List<Integer> subList;  
30.             if(i==threadCounts-1){  
31.                 subList=list.subList(i*len,list.size());  
32.             }else{  
33.                 subList=list.subList(i*len, len*(i+1)>list.size()?list.size():len*(i+1));  
34.             }  
35.             //採用匿名內部類實現  
36.             callList.add(new Callable<Long>(){  
37.                 public Long call() throws Exception {  
38.                     long subSum=0L;  
39.                     for(Integer i:subList){  
40.                         subSum+=i;  
41.                     }  
42.                     System.out.println("分配給執行緒："+Thread.currentThread().getName()+"那一部分List的整數和為：\tSubSum:"+subSum);  
43.                     return subSum;  
44.                 }  
45.             });  
46.         }  
47.         List<Future<Long>> futureList=exec.invokeAll(callList);  
48.         for(Future<Long> future:futureList){  
49.             sum+=future.get();  
50.         }  
51.         exec.shutdown();  
52.         System.out.println(sum);  
53.     }  
54. }  

我一直相信：討論是解決問題、提高水平的最佳方式！