Scalaコレクションをスレッドセーフに更新する

Question

不変のスカラコレクションを安全に更新するための「簡単な」方法があるかどうかは疑問でした。次のコードを検討してください：

class a { 
    private var x = Map[Int,Int]() 

    def update(p:(Int,Int)) { x = x + (p) } 
} 

このコードはスレッドセーフではありませんが、正しいですか？これは、updateメソッドを呼び出す2つのスレッドがあり、xが{1 => 2}のマップであり、スレッドAがupdate（（3,4））を呼び出すとx +（p）を実行するだけの場合、コードの一部。その後、再スケジューリングが発生し、スレッドBはupdate（（13,37））を呼び出し、変数xを正常に更新します。スレッドAは継続して終了します。

これで、値xは{1 => 2、3 => 4}のマップと等しくなりますか？希望の{1 => 2,3、> 4,13 => 37}の代わりに。それを修正する簡単な方法はありますか？

Btw、私はAkka STMのようなソリューションがあることを知っていますが、私は必要がない限り、それらを使用したくないと思います。

ありがとうございました！

編集：また、私はロックなしの解決策を好むでしょう。 Eeeew :)

Answer 1

あなたのケースでは、Maurícioが書いたように、コレクションは不変であるため、すでにスレッドセーフです。唯一の問題は、アトミック操作ではないvarを再割り当てすることです。この特定の問題については、java.util.concurrent.atomicの素敵なクラス、つまりAtomicReferenceを使うのが最も簡単な方法です。

import java.util.concurrent.atomic.AtomicReference 

class a { 
    private val x = new AtomicReference(Map[Int,Int]()) 

    def update(p:(Int,Int)) { 
    while (true) { 
     val oldMap = x.get // get old value 
     val newMap = oldMap + p // update 
     if (x.compareAndSet(oldMap, newMap)) 
     return // exit if update was successful, else repeat 
    } 
    } 
} 

Answer 2

コレクション自体は、共有可能な可変状態を持たないため、スレッドセーフですが、コードが変更されていないため、ロックされていない状態でこれを修正する方法はありません。あなたの最善の選択肢は、メソッド自体を同期としてマークすることです。

他の解決策は、おそらくjava.util.concurrent.ConcurrentMapの可変同時マップを使用することです。

Answer 3

Re。ジャン=フィリップ・ペレットの答え：あなたは、再利用可能なこの少しを行うことができます。

def compareAndSetSync[T](ref: AtomicReference[T])(logic: (T => T)) { 
    while(true) { 
    val snapshot = ref.get 
    val update = logic(snapshot) 
    if (ref.compareAndSet(snapshot, update)) return 
    } 
} 

def compareSync[T,V](ref: AtomicReference[T])(logic: (T => V)): V = { 
    var continue = true 
    var snapshot = ref.get 
    var result = logic(snapshot) 
    while (snapshot != ref.get) { 
    snapshot = ref.get 
    result = logic(snapshot) 
    } 
    result 
} 

Answer 4

1. ボックスのうち
2. アトミック
3. ロックフリー
4. O（1）

チェックこのアウト：http://www.scala-lang.org/api/2.11.4/index.html#scala.collection.concurrent.TrieMap