1

我有一个函数可以将数组拆分成更小的部分。
然后在单独的线程中评估每个部分。
结果被填充到一个通用列表中。 

private void sortandkeep(int[] arr){
        traversed.add(arr);
        if(arr.length==1) return;
        List<Integer> layer=new ArrayList<Integer>();
        //Divide the layer into different parts for a barrier to be set up.
        //After the barrier is broken,the layer is added to the main list
        if(arr.length>4){
            List<int[]> parts=split(arr);//smaller split pieces are populated on the list
            CyclicBarrier barrier = new CyclicBarrier(parts.size());
            for(int[] e:parts){
                Thread t=new Thread(new sortingThread(barrier,e,layer));
                t.start();
            }
        }
        else
            .........
        //The main thread should not proceed,unless the above barrier is broken
        sortandkeep(toIntArray(layer));
    }

我本来希望 sortandkeep 递归等待障碍被打破。
当所有工作线程都调用了 await 时，就会发生这种情况。
然而，事实并非如此。
主线程不断递归 - 无论工作线程的状态如何。这是怎么回事？

4

1 回答 1

1

如果主线程必须等待所有其他线程完成它们的任务，那么该线程就是必须通过屏障的参与方之一，并且它也必须await在继续之前调用。

// [...]
    CyclicBarrier barrier = new CyclicBarrier(parts.size() + 1); // sorting threads AND main thread
    for(int[] e:parts){
        Thread t=new Thread(new sortingThread(barrier,e,layer));
        t.start();
    }
} else 
        // [...]
//The main thread should not proceed, unless the above barrier is broken
barrier.await();
sortandkeep(toIntArray(layer));
// [...]
于 2014-07-02T20:10:31.360 回答