原子操作是指在多线程中的一个不可分割的操作单元。在一个原子操作中要么所有步骤都执行要么所有操作都不执行。比如在进行转账的时候甲向乙转账100元就是甲的钱减少100元乙的钱多100元如果因为某种原因而导致转账失败那么整个操作都要回滚否则就会导致数据不一致。原子操作的时候需要导包import std.sync.*一、整数类型的原子操作整数类型原子操作支持基本的读写、交换以及算数运算符操作。package Study // 导包 import std.sync.* import std.collection.* let counter AtomicInt64(100) main () { let futures ArrayListFutureInt64() // 创建100个子线程 for (_ in 0..100) { let future spawn { // 在每个子线程中增加这里是原子操作 counter.fetchAdd(1) } // 将子线程对应的Future实例添加到futures中 futures.add(future) } // 等待所有子线程执行结束 for (future in futures) { // 阻塞主线程直到future对应的子线程执行结束 future.get() } println(counter.load()) }二、布尔类型的原子类型布尔类型的原子操作支持基本的读写、交换操作。package Study // 导包 import std.sync.* import std.random.Random import std.collection.* // 标记电话是否正在接听初始不接听 let isCalling AtomicBool(false) func callControl() { // 如果电话正在接听则输出信息 if (isCalling.load()) { println(线程${Thread.currentThread.id} 正在等待接听) } // 当前线程在接听空闲时接听 while (true) { // 在设置接听标记为true后开始接听 if (isCalling.compareAndSwap(false, true)) { println(线程${Thread.currentThread.id} 正在接听) // 模拟通话时间 sleep(Duration.millisecond * Random().nextInt64(5000)) println(线程${Thread.currentThread.id} 接听结束) // 设置接通为false isCalling.store(false) break } } } main () { // 创建一个list存储所有子线程实例 let list ArrayListFutureUnit() // 创建5个电话子线程 for (_ in 0..5) { let future spawn { callControl() } // 将子线程对应的Future实例添加到list list.add(future) } // 等待所有子线程执行结束 for (future in list) { // 阻塞主线程,直到子线程执行结束 future.get() } println(所有通话结束) }三、引用类型的原子操作引用类型的原子操作支持基本的读写、交换操作。package Study // 导包 import std.sync.* import std.collection.* // 使用AtomicReference安全处理缓存对象 let cache AtomicReference(CacheObject()) // 模拟缓存对象 class CacheObject { CacheObject(var data: String){} } /* * 更新缓存信息 */ func updateCache(data: String) { while (true) { let expectedCache cache.load() let newChcae CacheObject(data) if (cache.compareAndSwap(expectedCache, newChcae)) { println(缓存更新: ${newChcae.data}) break } } } main () { let futureList ArrayListFutureUnit() for (i in 0..3) { let future spawn { updateCache(i.toString()) } // 将子线程对应的Future实例添加到list中 futureList.add(future) } // 等待所有子线程执行结束 for (future in futureList) { // 阻塞主线程 future.get() } }四、小结本章为大家详细的介绍了仓颉编程语言中原子操作的内容下一章为大家带来可重入互斥锁的内容。最后创作不易如果大家觉得我的文章对学习仓颉服务端开发有帮助的话就动动小手点个免费的赞吧收到的赞越多我的创作动力也会越大哦谢谢大家
跟我一起学“仓颉”编程语言-原子操作
原子操作是指在多线程中的一个不可分割的操作单元。在一个原子操作中要么所有步骤都执行要么所有操作都不执行。比如在进行转账的时候甲向乙转账100元就是甲的钱减少100元乙的钱多100元如果因为某种原因而导致转账失败那么整个操作都要回滚否则就会导致数据不一致。原子操作的时候需要导包import std.sync.*一、整数类型的原子操作整数类型原子操作支持基本的读写、交换以及算数运算符操作。package Study // 导包 import std.sync.* import std.collection.* let counter AtomicInt64(100) main () { let futures ArrayListFutureInt64() // 创建100个子线程 for (_ in 0..100) { let future spawn { // 在每个子线程中增加这里是原子操作 counter.fetchAdd(1) } // 将子线程对应的Future实例添加到futures中 futures.add(future) } // 等待所有子线程执行结束 for (future in futures) { // 阻塞主线程直到future对应的子线程执行结束 future.get() } println(counter.load()) }二、布尔类型的原子类型布尔类型的原子操作支持基本的读写、交换操作。package Study // 导包 import std.sync.* import std.random.Random import std.collection.* // 标记电话是否正在接听初始不接听 let isCalling AtomicBool(false) func callControl() { // 如果电话正在接听则输出信息 if (isCalling.load()) { println(线程${Thread.currentThread.id} 正在等待接听) } // 当前线程在接听空闲时接听 while (true) { // 在设置接听标记为true后开始接听 if (isCalling.compareAndSwap(false, true)) { println(线程${Thread.currentThread.id} 正在接听) // 模拟通话时间 sleep(Duration.millisecond * Random().nextInt64(5000)) println(线程${Thread.currentThread.id} 接听结束) // 设置接通为false isCalling.store(false) break } } } main () { // 创建一个list存储所有子线程实例 let list ArrayListFutureUnit() // 创建5个电话子线程 for (_ in 0..5) { let future spawn { callControl() } // 将子线程对应的Future实例添加到list list.add(future) } // 等待所有子线程执行结束 for (future in list) { // 阻塞主线程,直到子线程执行结束 future.get() } println(所有通话结束) }三、引用类型的原子操作引用类型的原子操作支持基本的读写、交换操作。package Study // 导包 import std.sync.* import std.collection.* // 使用AtomicReference安全处理缓存对象 let cache AtomicReference(CacheObject()) // 模拟缓存对象 class CacheObject { CacheObject(var data: String){} } /* * 更新缓存信息 */ func updateCache(data: String) { while (true) { let expectedCache cache.load() let newChcae CacheObject(data) if (cache.compareAndSwap(expectedCache, newChcae)) { println(缓存更新: ${newChcae.data}) break } } } main () { let futureList ArrayListFutureUnit() for (i in 0..3) { let future spawn { updateCache(i.toString()) } // 将子线程对应的Future实例添加到list中 futureList.add(future) } // 等待所有子线程执行结束 for (future in futureList) { // 阻塞主线程 future.get() } }四、小结本章为大家详细的介绍了仓颉编程语言中原子操作的内容下一章为大家带来可重入互斥锁的内容。最后创作不易如果大家觉得我的文章对学习仓颉服务端开发有帮助的话就动动小手点个免费的赞吧收到的赞越多我的创作动力也会越大哦谢谢大家
