حماية الحالة المشتركة بالحد الذري المناسب

import java.util.concurrent.atomic.AtomicInteger

fun main() {
    val completed = AtomicInteger(0)
    println(completed.incrementAndGet())
    println(completed.addAndGet(2))
    println(completed.get())
}

1
3
3

المخرجات المتوقعة هي 1 ثم 3 ثم 3. الشيفرة متتابعة وتحتاج واجهات JVM، ولم تُترجم. تأتي ضمانات الذرية من عقد الواجهة الموثق، لا من هذا المثال غير المنفذ.

import kotlinx.coroutines.*
import kotlinx.coroutines.sync.Mutex
import kotlinx.coroutines.sync.withLock

fun main() = runBlocking {
    val mutex = Mutex()
    var count = 0
    coroutineScope {
        repeat(2) {
            launch(Dispatchers.Default) {
                repeat(2) { mutex.withLock { count += 1 } }
            }
        }
    }
    println(count)
}

4

المخرج المتوقع 4 إذا بُني البرنامج ونُفّذ مع kotlinx.coroutines متوافقة. تأتي القراءة النهائية بعد اكتمال النطاق. لم يُختبر في بيئة التأليف مترجم أو موزّع أو سباق أو توقيت.