Как реализовать массив летучих элементов

Question

Я пытаюсь перенести приложение Java на Scala. Одна часть Java-приложения имеет реализацию под названием AtomicDoubleBuffer, которая использует AtomicLongArray под капотом - используя результат Double.longBitsToDouble(value) для чтения из двойного буфера и Double.doubleToRawLongBits(value) для записи в буфер.

Я искал вокруг сети для реализации Scala, которые могли бы быть лучше, и я приземлился на this, который говорит, что этот блок кода

class VolatileDoubleArray(val length : Int){ 
    val array = new Array[Double](length); 
    @volatile var marker = 0; 
    def apply(i : Int) = {marker; array(i); } 
    def update(i : Int, x : Double) { array(i) = x; marker = 0; } 
} 

должен дать мне происходит, прежде, чем гарантии. Но я немного смущен, насколько это возможно. Почему волатильный маркер на одной переменной определяет, что предыдущая энергонезависимая «операция» преуспевает? Моя интерпретация JSL 17.4.5 предполагает, что обновление элементов array в одном потоке не гарантирует, что другие потоки будут видеть это обновление. Я что-то упускаю? Или я сбиваю с толку все, что происходит раньше?

Answer 1

Эта реализация в вашем примере верна и делает ошибки до.

Becuse записи в энергонезависимую переменной делает все вещи, сделанные до в поток записи видимого на все темы что первый читать эту летучую переменную.

В этом случае изменчивая переменная «маркер» является точкой барьера памяти.

в вашем примере кода: «

class VolatileDoubleArray(val length : Int){ 
    val array = new Array[Double](length); 
    @volatile var marker = 0; 
    def apply(i : Int) = {marker; array(i); } 
    def update(i : Int, x : Double) { array(i) = x; marker = 0; } 
} 

»

, когда вы пишете в массив в update вы также записать в энергонезависимую переменную сразу после этого с помощью marker=0;, и перед любым читать в apply из массива вы сначала читаете переменную volatile только с помощью инструкции marker;.

Это делает любые записи в массив (даже выполненные разными потоками) видимыми для любых чтений (происходит до гарантии, в этом случае после завершения любого update, любой поток, выполняющий apply, увидит его).