在多个线程中洗牌阵列

Question

我有一个大小为N的数组.我想在2个线程(或更多)中将其元素洗牌.每个线程都应该使用它自己的数组部分.

可以说,第一个线程将元素从0移动到K,第二个线程将元素从K移动到N(其中0 <K <N).所以,它看起来像这样:

//try-catch stuff is ommited
static void shuffle(int[] array) {
   Thread t1 = new ShufflingThread(array, 0, array.length / 2);
   Thread t2 = new ShufflingThread(array, array.length / 2, array.length);
   t1.start();
   t2.start();
   t1.join();
   t2.join();
}

public static void main(String[] args) {
   int array = generateBigSortedArray();
   shuffle(array);
}

是否有从JVM任何担保,我会看到的变化array从main这样的洗牌后的方法？

为了获得这样的保证ShufflingThread,我应该如何实施(或者,我应该如何运行它,可能在一个synchronized区块内或其他任何区域内)？

Answer 1

该join()电话是足以保证内存一致性:当t1.join()返回时,主线程"看到"的任何操作线t1阵列上一样.

此外,Java保证阵列上没有单词撕裂:不同的线程可以使用同一阵列的不同元素而无需同步.

Answer 2

Thread.start() 和 Thread.join() 足以为您提供数组初始化、将其移交给线程以及然后在 main 方法中读回之间的发生之前关系。

导致发生之前的操作记录在此处。

正如其他地方提到的，ForkJoin 非常适合这种分而治之的算法，并将您从原本需要实现的大量簿记工作中解放出来。