黑马程序员技术交流社区

标题: 利用java线程并发库CyclicBarrier启动N个线程对二维矩阵进行求和。 [打印本页]
作者: Lin0411    时间: 2014-5-2 11:11
标题: 利用java线程并发库CyclicBarrier启动N个线程对二维矩阵进行求和。
  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. }

  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. }

  78. 这个例子让我体会到了并发库的强大。
复制代码
作者: 许庭洲    时间: 2014-5-5 13:29
值得学习ing!



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2