kotlin协程线程安全数据结构AtomicInteger原子同步

╰+哭是因爲堅強的太久メ 2023-09-24 21:07 56阅读 0赞

例如：

import kotlinx.coroutines.*
    import java.util.concurrent.Executors
    import java.util.concurrent.atomic.AtomicInteger
    
    fun main(args: Array<String>) {
        val coroutineDispatcher = Executors.newSingleThreadExecutor().asCoroutineDispatcher()
        val coroutineScope = CoroutineScope(coroutineDispatcher)
    
        var count = AtomicInteger()
        println(count)
    
        runBlocking {
            val job1 = coroutineScope.async {
                repeat(500) {
                    count.incrementAndGet()
                }
    
                "OK1"
            }
    
            val job2 = coroutineScope.async {
                delay(1_000)
                "OK2"
            }
    
            println(job1.await())
            println(job2.await())
        }
    
        println("count: ${count.get()}")
        coroutineDispatcher.close() //如果没有这句，main()函数将不会退出，一直处于运行状态
    }

输出：

> 0  
> OK1  
> OK2  
> count: 500

[kotlin AtomicBoolean compareAndSet\_zhangphil的博客-CSDN博客写一个简单代码：public class Main \{ private static boolean RUN = true;...\_多线程的共享变量必须加volatile。Java多线程同步：为什么要引入volatile？\_多线程的共享变量必须加volatile\_zhangphil的博客-CSDN博客。![favicon32.ico][]https://blog.csdn.net/zhangphil/article/details/130094908][kotlin AtomicBoolean compareAndSet_zhangphil_-CSDN_public class Main _ private static boolean RUN _ true_..._volatile_Java_volatile_volatile_zhangphil_-CSDN_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_130094908]

[favicon32.ico]: https://g.csdnimg.cn/static/logo/favicon32.ico
[kotlin AtomicBoolean compareAndSet_zhangphil_-CSDN_public class Main _ private static boolean RUN _ true_..._volatile_Java_volatile_volatile_zhangphil_-CSDN_favicon32.ico_https_blog.csdn.net_zhangphil_article_details_130094908]: https://blog.csdn.net/zhangphil/article/details/130094908