Наблюдение за памятью в вилке-присоединении

Question

Брайан Гетц написал хорошую статью о fork-join на http://www.ibm.com/developerworks/java/library/j-jtp03048.html. В нем он перечисляет алгоритм сортировки слияния, используя механизм fork-join, в котором он выполняет сортировку с двух сторон массива параллельно, а затем объединяет результат.

Алгоритм сортируется по двум различным разделам одного и того же массива одновременно. Почему для поддержания видимости не требуется AtomicIntegerArray или какой-либо другой механизм? Какая гарантия, что один поток увидит записи, сделанные другим, или это тонкая ошибка? В качестве продолжения, делает ли Scala ForkJoinScheduler эту гарантию?

Спасибо!

Answer 1

Для соединения (из ForkJoin) требуется точка синхронизации, то есть самая важная часть информации. Точка синхронизации гарантирует, что все записанные записи будут видны после указанной точки.

Если вы посмотрите на код, вы увидите, где находится точка синхронизации. Это только один вызов метода invokeAll

public static void invokeAll(ForkJoinTask<?> t1, ForkJoinTask<?> t2) { 
    t2.fork(); 
    t1.invoke(); 
    t2.join(); 
} 

Здесь t2 вилы в другой процесс, t1 выполняет свою задачу, и вызывающий поток будет ждать t2.join(). При передаче t2. Затем все записи в t1 и t2 будут видны.

Редактировать: Это изменение только для того, чтобы дать более подробное объяснение того, что я имел в виду под точкой синхронизации.

Допустим, что у вас есть две переменные

int x; 
volatile int y; 

Каждый раз, когда вы пишете у всех пишет, что произошло, прежде чем читать у будет доступен. Например

public void doWork(){ 
    x = 10; 
    y = 5; 
} 

Если другой поток читает у = 5, что нить гарантируется для чтения х = 10. Это потому, что записи в у создает точку синхронизации, в которой все операции записи перед указанной точкой будет видимый после записи.

С помощью вилки Join pool объединение ForkJoinTask создаст точку синхронизации. Теперь, если t2.fork() и t1.invoke(), объединение t2 будет гарантировать, что все записи, которые ранее произошли, будут видны. Поскольку все предыдущие записи находятся в одной структуре, это будет безопасно для видимости.

Я был бы рад объяснить, если это не так ясно.

Answer 2

Просто догадка: объединение включает присоединение к потоку, и соединение гарантирует видимость.

Вторая часть уверена; Я не знаю, как реализовано объединение.