1. public class SolverTest
   
2. {
   
3.         public static void main(String[] args)
   
4.         {
   
5.                 int[][] data = {{1,2,3},{3,4,5},{5,6,7}};
   
6.                 System.out.println(new Solver(data).SUM+"");
   
7.         }
   
8. }
   
9. 
   
10. class Solver
    
11. {
    
12.         private  int N=0;
    
13.         private CyclicBarrier barrier=null;
    
14.         private int[][] data=null;                  //二维数组矩阵
    
15.         private int sumRow[] = null;          //存储每行的数据和
    
16.         private ExecutorService executorService=null;
    
17.        
    
18.         public int SUM;               //矩阵所有数据的总和
    
19.        
    
20.         class Worker implements Runnable
    
21.         {
    
22.                 int myRow;
    
23.                 public Worker(int myRow)
    
24.                 {
    
25.                         this.myRow = myRow;
    
26.                 }
    
27.                
    
28.                 public void run()
    
29.                 {       
    
30.                                 processRow(myRow);
    
31.                                 try
    
32.                                 {
    
33.                                         barrier.await();
    
34.                                 }
    
35.                                 catch (Exception e)
    
36.                                 {
    
37.                                         return;
    
38.                                 }
    
39.                        
    
40.                 }
    
41.                
    
42.                 public void processRow(int myRow)
    
43.                 {
    
44.                         for(int i=0; i<data[myRow].length; i++)
    
45.                                 sumRow[myRow] += data[myRow][i];
    
46.                 }
    
47.         }
    
48.        
    
49.         public Solver(int[][] matrix)
    
50.         {
    
51.                 this.data = matrix;
    
52.                 this.N = matrix.length;
    
53.                 this.sumRow = new int[N];
    
54.                 this.executorService = Executors.newFixedThreadPool(this.N);
    
55.                 this.barrier = new CyclicBarrier(N, new Runnable()
    
56.                 {               
    
57.                         public void run()
    
58.                         {
    
59.                                 mergeRows();
    
60.                         }
    
61.                 });
    
62.                
    
63.                 for(int i=0; i<this.N; i++)
    
64.                 {
    
65.                         this.executorService.submit(new Worker(i));
    
66.                 }
    
67.                
    
68.                 this.executorService.shutdown();
    
69.         }
    
70.        
    
71.         public void mergeRows()
    
72.         {
    
73.                 for(int i=0; i<N; i++)
    
74.                         SUM += sumRow[i];
    
75.         }
    
76. }
    
77. 
    
78. 这个例子让我体会到了并发库的强大。

复制代码

值得学习ing!