如何在android上的多线程中创建屏障

Question

我在 Linux 上的多线程项目中需要一个屏障。我知道 pthread_barrier_init() 和 pthread_barrier_wait()，但我想在 android 上运行我的项目。它没有这些功能。我知道如何使用原子添加和原子比较来实现它。我想用信号量，可以用信号量来实现吗？

Answer 1

使用CyclicBarrier，这或多或少与 pthread 屏障相同。

示例代码（来自链接页面）

 class Solver {
   final int N;
   final float[][] data;
   final CyclicBarrier barrier;

   class Worker implements Runnable {
     int myRow;
     Worker(int row) { myRow = row; }
     public void run() {
       while (!done()) {
         processRow(myRow);

         try {
           barrier.await();
         } catch (InterruptedException ex) {
           return;
         } catch (BrokenBarrierException ex) {
           return;
         }
       }
     }
   }

   public Solver(float[][] matrix) {
     data = matrix;
     N = matrix.length;
     barrier = new CyclicBarrier(N,
                                 new Runnable() {
                                   public void run() {
                                     mergeRows(...);
                                   }
                                 });
     for (int i = 0; i < N; ++i)
       new Thread(new Worker(i)).start();

     waitUntilDone();
   }
 }