县城_Kotlin协程不安全的并发/安全的并发

篇首语：本文由编程笔记#小编为大家整理，主要介绍了Kotlin 协程 不安全的并发/安全的并发相关的知识，希望对你有一定的参考价值。

class CoroutineText03
&＃64;Test
fun &＃96;test not safe concurrent&＃96;() &＃61; runBlocking
var count &＃61; 0
List(1000)
GlobalScope.launch count&＃43;&＃43;
.joinAll()
println(count)



结果不是固定的。。

因为 他们不是原子性的操作。在a&＃43;1&＃61;b的时候  没有进行b&＃43;1 而是又跑了一遍a&＃43;1

就没有计算到结果当中

可以使用

&＃64;Test
fun &＃96;test safe concurrent&＃96;() &＃61; runBlocking
var count &＃61; AtomicInteger(0)
List(1000)
GlobalScope.launch count.incrementAndGet()
.joinAll()
println(count)


来保证其源自顺序

 AtomicInteger 是来自java的东西。

协程也提供了并发安全

1、Channel

2、Mutex 轻量级锁

他的lock和unlock从语义上与线程锁比较类似&＃xff0c;之所以轻量&＃xff0c;是因为它在获取不到锁时不会阻塞县城。而是挂起等待锁的释放

&＃64;Test
fun &＃96;test safe concurrent tools&＃96;() &＃61; runBlocking
var count &＃61; 0
val mutex &＃61; Mutex()
List(1000)
GlobalScope.launch
mutex.withLock
count&＃43;&＃43;


.joinAll()
println(count)



3 Semaphore:轻量级信号量&＃xff0c;信号量可以有多个&＃xff0c;协程在获取到信号量后即可执行并发操作

&＃64;Test
fun &＃96;test safe concurrent tools2&＃96;() &＃61; runBlocking
var count &＃61; 0
val semaphore &＃61; Semaphore(1)
List(1000)
GlobalScope.launch
semaphore.withPermit
count&＃43;&＃43;


.joinAll()
println(count)



安全的都是返回1000不再打印

还有一种。。在外面加 不过这种应该是效率没有很高。

&＃64;Test
fun &＃96;test avoid access outer variable&＃96;() &＃61; runBlocking
val count &＃61; 0
val result &＃61; count &＃43; List(1000)
GlobalScope.async 1
.map it.await() .sum()
println(result)