Migrate to the new memory model

Author: KaterinaPetrova

build.gradle

@@ -0,0 +1,44 @@
+plugins {
+ id("org.jetbrains.kotlin.multiplatform") version "1.6.0-M1-139"
+}
+repositories {
+ mavenCentral()
+ maven {
+ url = uri("https://maven.pkg.jetbrains.space/kotlin/p/kotlin/dev")
+ }
+}
+
+val hostOs = System.getProperty("os.name")
+val isLinux = hostOs == "Linux"
+val isWindows = hostOs.startsWith("Windows")
+
+kotlin {
+
+ if (isLinux){
+ linuxX64("native")
+ } else if(isWindows){
+ mingwX64("native")
+ }else {
+ macosX64("native")
+ }
+
+ sourceSets {
+ val nativeMain by getting {
+ dependencies {
+ implementation("co.touchlab:stately-concurrency:1.1.7")
+ }
+ }
+ }
+
+ targets.withType<org.jetbrains.kotlin.gradle.plugin.mpp.KotlinNativeTarget> {
+ binaries {
+ executable {
+ entryPoint = "sample.main"
+ }
+ }
+ }
+}
+
+// Use the following Gradle tasks to run your application:
+// :runReleaseExecutableMacos - without debug symbols
+// :runDebugExecutableMacos - with debug symbols

build.gradle.kts

@@ -1,2 +1,3 @@
 kotlin.code.style=official
-kotlin.import.noCommonSourceSets=true
+kotlin.import.noCommonSourceSets=true
+kotlin.native.binary.memoryModel=experimental

gradle.properties

@@ -1 +1,10 @@
-rootProject.name = 'KNConcurrencySamples'
+pluginManagement {
+ repositories {
+ maven {
+ url "https://maven.pkg.jetbrains.space/kotlin/p/kotlin/dev"
+ }
+ gradlePluginPortal()
+ }
+}
+
+rootProject.name = 'KNConcurrencySamples'

settings.gradle

@@ -24,7 +24,7 @@ fun captureTooMuch(){
  println("I have ${model.count}")
 
  model.increment()
- println("I have ${model.count}") //We won't get here
+ println("I have ${model.count}") // We will get here the new MM
 }
 
 class CountingModel{

src/nativeMain/kotlin/sample/Background.kt

@@ -4,10 +4,9 @@ import co.touchlab.stately.concurrency.ThreadRef
 import kotlin.native.concurrent.Future
 import kotlin.native.concurrent.TransferMode
 import kotlin.native.concurrent.Worker
-import kotlin.native.concurrent.freeze
 
 fun background(block: () -> Unit) {
- val future = worker.execute(TransferMode.SAFE, { block.freeze() }) {
+ val future = worker.execute(TransferMode.SAFE, { block }) {
  it()
  }
  collectFutures.add(future)
@@ -27,7 +26,6 @@ fun teardownThreading() {
  worker.requestTermination()
 }
 
-@SharedImmutable
 private val mainThreadRef: ThreadRef by lazy {
  ThreadRef()
 }

src/nativeMain/kotlin/sample/BackgroundSupport.kt

@@ -19,14 +19,14 @@ fun ensureNeverFrozenBackground() {
  val sd = SomeData("a", 1)
  sd.ensureNeverFrozen()
  background {
- println("Won't get here $sd")
+ println("We will get here with the new MM $sd")
  }
 }
 
 fun captureTooMuchInit() {
  val model = CountingModelEnsure()
  model.increment()
- println("I have ${model.count}") //We won't even get here
+ println("I have ${model.count}") //We will get here with the new MM
 }
 
 class CountingModelEnsure{

src/nativeMain/kotlin/sample/Debugging.kt

@@ -7,7 +7,7 @@ import kotlin.native.concurrent.Worker
 fun cantChangeThis(){
  println("i ${DefaultGlobalState.i}")
  DefaultGlobalState.i++
- println("i ${DefaultGlobalState.i}") //We won't get here
+ println("i ${DefaultGlobalState.i}") // We will get here with the new MM
 }
 
 object DefaultGlobalState{
@@ -37,7 +37,7 @@ fun threadLocalDifferentThreads(){
 fun companionAlsoFrozen(){
  println("i ${GlobalStateCompanion.i}")
  GlobalStateCompanion.i++
- println("i ${GlobalStateCompanion.i}") //We won't get here
+ println("i ${GlobalStateCompanion.i}") // We will get here with the new MM
 }
 
 class GlobalStateCompanion{
@@ -55,7 +55,7 @@ fun globalCounting(){
 
 var globalCounterData = SomeMutableData(33)
 
-fun globalCountingFail(){
+fun globalCountingDontFail(){
  background {
  try {
  globalCounterData.i++
@@ -69,6 +69,6 @@ fun globalCountingFail(){
 @SharedImmutable
 val globalCounterDataShared = SomeMutableData(33)
 
-fun globalCountingSharedFail(){
+fun globalCountingSharedDontFail(){
  globalCounterDataShared.i++
 }

src/nativeMain/kotlin/sample/GlobalState.kt

@@ -20,7 +20,7 @@ fun main() {
 // threadLocalDifferentThreads()
 // companionAlsoFrozen()
 // globalCounting()
-// globalCountingFail()
+// globalCountingDontFail()
 // globalCountingSharedFail()
 
  // 4) Background