core

coroutine scope

Author: lotharschulz

app/build.gradle.kts

@@ -9,6 +9,7 @@ repositories {
 
 dependencies {
     implementation("org.redisson:redisson:3.19.3")
+    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.3")
 
     testImplementation("org.jetbrains.kotlin:kotlin-test-junit5")
     testImplementation("org.junit.jupiter:junit-jupiter-engine:5.9.1")

app/src/main/kotlin/redis_kotlin/App.kt

@@ -2,6 +2,7 @@ package redis_kotlin
 
 import io.reactivex.rxjava3.core.Completable
 import io.reactivex.rxjava3.core.Single
+import kotlinx.coroutines.*
 import org.redisson.Redisson
 import org.redisson.RedissonMultiLock
 import org.redisson.api.*
@@ -10,8 +11,6 @@ import org.redisson.config.Config
 import reactor.core.publisher.Mono
 import java.io.Serializable
 import java.time.Duration;
-import java.util.concurrent.TimeUnit
-
 
 data class Book(val pages: Int, val chapter: Int, val author: String) : Serializable
 
@@ -90,34 +89,6 @@ class App {
         myAtomicLong.unlink() // clean up, happens async
         println("myAtomicLong after unlink/cleanup: $myAtomicLong")
     }
-
-    private fun atomicLongCoroutines(redisson: RedissonClient, newValue: Long) {
-        printHelper("atomicLong corountines")
-        val myAtomicLong: RAtomicLong = redisson.getAtomicLong("myAtomicLongCoRoutine")
-        println("initial myAtomicLong: $myAtomicLong")
-    
-        val job = GlobalScope.launch {
-            for (i in 1..7) {
-                myAtomicLong.incrementAndGet()
-                println("myAtomicLong after increment and set: $myAtomicLong (loop run # $i)")
-            }
-        }
-        // Waiting for the increments to finish
-        job.join()
-        
-        val jobs = mutableListOf<Job>()
-        repeat(1) {
-            jobs.add(GlobalScope.launch {
-                myAtomicLong.get()
-                println("myAtomicLong after get: $myAtomicLong")
-            })
-        }
-    
-        // Waiting for the jobs to finish
-        jobs.joinAll()
-        myAtomicLong.unlink() // clean up, happens async
-        println("myAtomicLong after unlink/cleanup: $myAtomicLong")
-    }
 
     private fun atomicLongReactive(redisson: RedissonClient, newValue: Long) {
         printHelper("atomicLong reactive interface")
@@ -162,6 +133,33 @@ class App {
         )
     }
 
+    private suspend fun atomicLongCoroutines(redisson: RedissonClient, newValue: Long) {
+        printHelper("atomicLong corountines")
+        val myAtomicLong: RAtomicLong = redisson.getAtomicLong("myAtomicLongCoRoutine")
+        println("initial myAtomicLong: $myAtomicLong")
+
+        val scope = CoroutineScope(Dispatchers.IO + SupervisorJob())
+        val incAndGetJob = scope.launch {
+            for (i in 1..7) {
+                myAtomicLong.incrementAndGet()
+                println("myAtomicLong after increment and set: $myAtomicLong (loop run # $i)")
+            }
+        }
+        // Waiting for the increments & gets to finish
+        incAndGetJob.join()
+
+        val getJob = scope.launch {
+            myAtomicLong.get()
+            println("myAtomicLong after get: $myAtomicLong")
+        }
+
+        // Waiting for the get job to finish
+        getJob.join()
+
+        myAtomicLong.unlink() // clean up, happens async
+        println("myAtomicLong after unlink/cleanup: $myAtomicLong")
+    }
+
     private fun bucket(redissonClient: RedissonClient, bucketName: String, value: String) {
         printHelper("bucket")
         val bucket = redissonClient.getBucket<String>(bucketName)
@@ -349,6 +347,9 @@ class App {
                 atomicLongReactive(redisson.redissonClient, 3L)
                 atomicLongRXJava3(redisson.redissonClient, 3L)
                 Thread.sleep(1000) // wait for 1 second to complete RX operations
+                runBlocking {
+                    atomicLongCoroutines(redisson.redissonClient, 3L)
+                }
                 bucket(redisson.redissonClient, "foo", "bar") // buckets
                 `object`(redisson.redissonClient, 100, 10, "some author")
                 topic(redisson.redissonClient, "new message")