iOS简单优雅的实现复杂情况下的串行需求(各种锁、GCD 、NSOperationQueue...)

2024-01-26 05:48
文章标签 简单 实现 优雅 ios 情况 需求 复杂 串行 gcd nsoperationqueue

本文主要是介绍iOS简单优雅的实现复杂情况下的串行需求(各种锁、GCD 、NSOperationQueue...)，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

iOS简单优雅的实现复杂情况下的串行需求(各种锁、GCD 、NSOperationQueue…)

昨天一个同事问我一个问题,我在开发中有很多异步操作,回调都需要时间,且时间都不确定,例如一个网络请求,就是这样的形式,异步发起请求,等待回调,等到获取结果之后进行下一步的操作.
我说,没有任何问题啊.本来耗时操作等就是这么写的啊…
然后他说,我现在有一个新的需求,例如网络请求1结束后请求2等到2回来之后再请求3….层层下去…按照顺序来,我说这个需求不算太难.
但是鉴于这个需求很多人都有可能会用到,于是我打算把它给写下来分享给大家

每一次的异步操作大概可以简化成如下:

-(void)doSomeThingForFlag:(NSInteger)flag finish:(void(^)())finshed{dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{NSLog(@"do:%ld",(long)flag);sleep(2+arc4random_uniform(4));NSLog(@"finish:%ld",(long)flag);if (finshed) {finshed();}});
}

那么正常情况下的写法就是直接按照顺序来

-(void)nomal{[self doSomeThingForFlag:1 finish:nil];[self doSomeThingForFlag:2 finish:nil];[self doSomeThingForFlag:3 finish:nil];[self doSomeThingForFlag:4 finish:nil];
}

那么这样有效果么?我们运行看看…
这里写图片描述
很显然,结果没有想象的那么简单,开始请求就已经是无序了…

没有办法,那么使用嵌套?就是最普通的方式看看,

/**逻辑嵌套*/
-(void)useNested{__weak typeof(self)weakSelf = self;[self doSomeThingForFlag:1 finish:^{[weakSelf doSomeThingForFlag:2 finish:^{[weakSelf doSomeThingForFlag:3 finish:^{[weakSelf doSomeThingForFlag:4 finish:nil];}];}];}];
}

这里写图片描述

OK ,结果完全按照想要的顺序1->2->3->4
但是这样写会不会就觉得很嵌套的太多了呢?有没有办法不使用这种嵌套来完成这个逻辑呢?
开始构思,首先想到的就是锁,是的,应用开发中有很多所能够完成
iOS作为源自C的更高级语言,自然而然也少不了有各种锁的实现.包含C语言的话,
有OSSpinLock、pthead、@synchronized、NSLock……大概7、8种以上吧..
在不考虑各种锁的性能的情况下,那么是不是所有的都特别适用呢?
我一个一个举例尝试,大致的思路就是创建一个锁,然后通过加锁和解锁的操作来实现串行的需求
首先是使用

pthread_mutex 互斥锁

#import <pthread.h>/**pthread_mutex 互斥锁*/
-(void)usePthred{static pthread_mutex_t pLock;pthread_mutex_init(&pLock, NULL);pthread_mutex_lock(&pLock);NSLog(@"1上锁");[self doSomeThingForFlag:1 finish:^{NSLog(@"1解锁");pthread_mutex_unlock(&pLock);}];pthread_mutex_lock(&pLock);NSLog(@"2上锁");[self doSomeThingForFlag:2 finish:^{NSLog(@"2解锁");pthread_mutex_unlock(&pLock);}];pthread_mutex_lock(&pLock);NSLog(@"3上锁");[self doSomeThingForFlag:3 finish:^{NSLog(@"3解锁");pthread_mutex_unlock(&pLock);}];pthread_mutex_lock(&pLock);NSLog(@"4上锁");[self doSomeThingForFlag:4 finish:^{NSLog(@"4解锁");pthread_mutex_unlock(&pLock);}];
}

好吧,轻易的实现了
这里写图片描述

那么既然互斥锁可以,我再试试另一种pthead

pthread_mutex(recursive) 递归锁

/**pthread_mutex(recursive) 递归锁*/
-(void)usePthredResursive{static pthread_mutex_t pLock;pthread_mutexattr_t attr;pthread_mutexattr_init(&attr); //初始化attr并且给它赋予默认pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE); //设置锁类型，这边是设置为递归锁pthread_mutex_init(&pLock, &attr);pthread_mutexattr_destroy(&attr); //销毁一个属性对象，在重新进行初始化之前该结构不能重新使用static void (^RecursiveBlock)(int);__weak typeof(self)weakSelf = self;RecursiveBlock = ^(int value) {pthread_mutex_lock(&pLock);if (value>0) {[weakSelf doSomeThingForFlag:5-value finish:^{RecursiveBlock(value-1);}];}//        if (value == 4) {//            [self doSomeThingForFlag:1 finish:^{//                RecursiveBlock(3);//            }];//        }//        if (value == 3) {//            [self doSomeThingForFlag:2 finish:^{//                RecursiveBlock(2);//            }];//        }//        if (value == 2) {//            [self doSomeThingForFlag:3 finish:^{//                RecursiveBlock(1);//            }];//        }//        if (value == 1) {//            [self doSomeThingForFlag:4 finish:^{//                RecursiveBlock(0);//            }];//        }pthread_mutex_unlock(&pLock);};RecursiveBlock(4);
}

递归锁允许同一个线程在未释放其拥有的锁时反复对该锁进行加锁操作。
结果也是可以能够实现的
这里写图片描述

表面上看感觉递归锁貌似是没有问题的 但是其实在这里锁并没有起到作用,这里的锁只是锁住了doSomeThingForFlag:finish: 这个方法而已
其实我们把这些全部去掉看看.

-(void)usePthredResursive{
//    static pthread_mutex_t pLock;
//    pthread_mutexattr_t attr;
//    pthread_mutexattr_init(&attr); //初始化attr并且给它赋予默认
//    pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE); //设置锁类型，这边是设置为递归锁
//    pthread_mutex_init(&pLock, &attr);
//    pthread_mutexattr_destroy(&attr); //销毁一个属性对象，在重新进行初始化之前该结构不能重新使用static void (^RecursiveBlock)(int);__weak typeof(self)weakSelf = self;RecursiveBlock = ^(int value) {
//        pthread_mutex_lock(&pLock);if (value>0) {[weakSelf doSomeThingForFlag:5-value finish:^{RecursiveBlock(value-1);}];}
//        pthread_mutex_unlock(&pLock);};RecursiveBlock(4);
}

这里写图片描述

结果也是一样?是的,没有想的那么高深,他只是上面嵌套的另一种写法而已,所以递归锁并没有效果,它只是锁住方法本身,保证一次只有一个执行而已,如果我们把block的调用放到方法的外面一样没有作用

-(void)usePthredResursive{static pthread_mutex_t pLock;pthread_mutexattr_t attr;pthread_mutexattr_init(&attr); //初始化attr并且给它赋予默认pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE); //设置锁类型，这边是设置为递归锁pthread_mutex_init(&pLock, &attr);pthread_mutexattr_destroy(&attr); //销毁一个属性对象，在重新进行初始化之前该结构不能重新使用static void (^RecursiveBlock)(int);__weak typeof(self)weakSelf = self;RecursiveBlock = ^(int value) {pthread_mutex_lock(&pLock);if (value>0) {[weakSelf doSomeThingForFlag:5-value finish:nil];RecursiveBlock(value-1);}pthread_mutex_unlock(&pLock);};RecursiveBlock(4);
}

这样的话就是没有达到需求
这里写图片描述

所以我打算放弃递归锁的实现,比如NSRecursiveLock,我直接放弃
联想到这样的方式,我打算再次放弃另外一种锁@synchronized 因为它也只能锁住方法的本身,并控制不了回调的结果

那么就么有方法了么?只能使用递归或者嵌套 或者互斥锁么?

C的方法我又想到了自旋锁

OSSpinLock 自旋锁

#import <libkern/OSAtomic.h>/**OSSpinLock 自旋锁*/
-(void)useOSSpinLock{__block OSSpinLock oslock = OS_SPINLOCK_INIT;OSSpinLockLock(&oslock);NSLog(@"1上锁");[self doSomeThingForFlag:1 finish:^{NSLog(@"1解锁");OSSpinLockUnlock(&oslock);}];OSSpinLockLock(&oslock);NSLog(@"2上锁");[self doSomeThingForFlag:2 finish:^{NSLog(@"2解锁");OSSpinLockUnlock(&oslock);}];OSSpinLockLock(&oslock);NSLog(@"3上锁");[self doSomeThingForFlag:3 finish:^{NSLog(@"3解锁");OSSpinLockUnlock(&oslock);}];OSSpinLockLock(&oslock);NSLog(@"4上锁");[self doSomeThingForFlag:4 finish:^{NSLog(@"4解锁");OSSpinLockUnlock(&oslock);}];
}

这里写图片描述

结果终于回到了想要的局面,OSSpinLock没有让我失望.

至此我就想到了,无上面写的方法基本上就是使用各种锁的实现,来达到需求,在结果回调前把线程给锁住,无法继续新的线程,知道该线程的锁解开

那么我们能不能使用多线程的某些方法来实现呢?比如阻塞线程,比如线程的暂停和恢复
首先想到的就是GCD
类似于OSSpinLock, 我们尝试使用GCD的信号量看看能不能够实现

dispatch_semaphore_t

/**GCD single*/
-(void)useGCDSingle{dispatch_semaphore_t semaphore = dispatch_semaphore_create(1);dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);NSLog(@"1阻塞线程");[self doSomeThingForFlag:1 finish:^{NSLog(@"1释放线程");dispatch_semaphore_signal(semaphore);}];dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);NSLog(@"2阻塞线程");[self doSomeThingForFlag:2 finish:^{NSLog(@"2释放线程");dispatch_semaphore_signal(semaphore);}];dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);NSLog(@"3阻塞线程");[self doSomeThingForFlag:3 finish:^ {NSLog(@"3释放线程");dispatch_semaphore_signal(semaphore);}];dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);NSLog(@"4阻塞线程");[self doSomeThingForFlag:4 finish:^{NSLog(@"4释放线程");dispatch_semaphore_signal(semaphore);}];
}

这里写图片描述

或者使用

dispatch_suspend、dispatch_resume

这里需要注意一些东西

  • dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0); //获得程序进程缺省产生的并发队列，可设定优先级来选择高、中、低三个优先级队列。由于是系统默认生成的，所以无法调用dispatch_resume()和dispatch_suspend()来控制执行继续或中断。
    那么想使用这个怎么办呢?
    我们可以这样想.因为这几个方法调用来看,大的方式是是串行队列,那么就创建一个串行队列以供暂停和恢复就好了
/**GCD队列的暂停和恢复*/
-(void)useGCDSuspendAndResume{dispatch_queue_t myqueue = dispatch_queue_create("com.charles.queue", NULL);dispatch_async(myqueue, ^{dispatch_suspend(myqueue);[self doSomeThingForFlag:1 finish:^(NSInteger flag) {dispatch_resume(myqueue);}];dispatch_suspend(myqueue);[self doSomeThingForFlag:2 finish:^(NSInteger flag) {dispatch_resume(myqueue);}];dispatch_suspend(myqueue);[self doSomeThingForFlag:3 finish:^(NSInteger flag) {dispatch_resume(myqueue);}];dispatch_suspend(myqueue);[self doSomeThingForFlag:4 finish:^(NSInteger flag) {dispatch_resume(myqueue);}];});
}

这里写图片描述

无效!我是哪里想错了么?
暂停恢复,想一想,串行队列嘛,当然要串行的添加啦,

/**GCD队列的暂停和恢复*/
-(void)useGCDSuspendAndResume{dispatch_queue_t myqueue = dispatch_queue_create("com.charles.queue", NULL);dispatch_async(myqueue, ^{dispatch_suspend(myqueue);[self doSomeThingForFlag:1 finish:^(NSInteger flag) {dispatch_resume(myqueue);}];});dispatch_async(myqueue, ^{dispatch_suspend(myqueue);[self doSomeThingForFlag:2 finish:^(NSInteger flag) {dispatch_resume(myqueue);}];});dispatch_async(myqueue, ^{dispatch_suspend(myqueue);[self doSomeThingForFlag:3 finish:^(NSInteger flag) {dispatch_resume(myqueue);}];});dispatch_async(myqueue, ^{dispatch_suspend(myqueue);[self doSomeThingForFlag:4 finish:^(NSInteger flag) {dispatch_resume(myqueue);}];});
}

这里写图片描述

果然,开始是我想错了….

那么既然GCD可以,我使用NSOperationQueue呢?

NSOperationQueue

/**operationQueue的暂停和恢复*/
-(void)useOperationQueue{NSOperationQueue *queue = [[NSOperationQueue alloc] init];[queue setMaxConcurrentOperationCount:1];__weak typeof(self)weakSelf = self;NSBlockOperation * operation1 = [NSBlockOperation blockOperationWithBlock:^{[queue setSuspended:YES];[weakSelf doSomeThingForFlag:1 finish:^(NSInteger flag) {[queue setSuspended:NO];}];}];NSBlockOperation * operation2 = [NSBlockOperation blockOperationWithBlock:^{[queue setSuspended:YES];[weakSelf doSomeThingForFlag:2 finish:^(NSInteger flag) {[queue setSuspended:NO];}];}];NSBlockOperation * operation3 = [NSBlockOperation blockOperationWithBlock:^{[queue setSuspended:YES];[weakSelf doSomeThingForFlag:3 finish:^(NSInteger flag) {[queue setSuspended:NO];}];}];NSBlockOperation * operation4 = [NSBlockOperation blockOperationWithBlock:^{[queue setSuspended:YES];[weakSelf doSomeThingForFlag:4 finish:^(NSInteger flag) {[queue setSuspended:NO];}];}];[operation4 addDependency:operation3];[operation3 addDependency:operation2];[operation2 addDependency:operation1];[queue addOperation:operation1];[queue addOperation:operation2];[queue addOperation:operation3];[queue addOperation:operation4];
}

完全参考GCD的思路,创建每一个操作,添加依赖和最大并发数保证大的串行,同是在没操作其中一个暂停队列,完成后恢复运行….
这里写图片描述

OK说了这么多,其实就是通过各种方式来实现我最上面提到的需求而已.
这样的操作真的有用么?
很碰巧,我最近在做蓝牙开发,有这样的类似需求,蓝牙发送指令并接收到设备端返回数据的情况就是一次类似的网络请求,
我碰到的需求是按顺序的设置指令到蓝牙设备端,如果是多个UUID或者characteristic的话,之间不冲突,没有影响,但是可惜的是我要操作的是一个characteristic,我只能这么做,因为如果同一时间发送指令不是按照上面的逻辑的话,就会造成丢包.我可能发送了某一个指令,但是蓝牙没有收到或者未处理就来了新的指令导致我无法完整的操作它.我必须保证1->2->3->4的逻辑顺序,

我很高兴我正好在研究这个,所以我能够即时的给到我同事我的思路,,并且今天把它分享给你们
附上demo的地址
https://github.com/spicyShrimp/specialSync.git

还有我写的系列文章,刚刚开始写,希望多关注一下.
系列:iOS开发-前言+大纲
http://blog.csdn.net/spicyShrimp/article/details/62218521

这篇关于iOS简单优雅的实现复杂情况下的串行需求(各种锁、GCD 、NSOperationQueue...)的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/645816。

相关文章

openCV中KNN算法的实现

openCV中KNN算法的实现

《openCV中KNN算法的实现》KNN算法是一种简单且常用的分类算法,本文主要介绍了openCV中KNN算法的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的... 目录KNN算法流程使用OpenCV实现KNNOpenCV 是一个开源的跨平台计算机视觉库，它提供了各
阅读更多...
OpenCV图像形态学的实现

OpenCV图像形态学的实现

《OpenCV图像形态学的实现》本文主要介绍了OpenCV图像形态学的实现,包括腐蚀、膨胀、开运算、闭运算、梯度运算、顶帽运算和黑帽运算,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起... 目录一、图像形态学简介二、腐蚀（Erosion）1. 原理2. OpenCV 实现三、膨胀China编程（
阅读更多...
通过Spring层面进行事务回滚的实现

通过Spring层面进行事务回滚的实现

《通过Spring层面进行事务回滚的实现》本文主要介绍了通过Spring层面进行事务回滚的实现,包括声明式事务和编程式事务,具有一定的参考价值,感兴趣的可以了解一下... 目录声明式事务回滚：1. 基础注解配置2. 指定回滚异常类型3. ​不回滚特殊场景编程式事务回滚：1. ​使用 TransactionT
阅读更多...
Android实现打开本地pdf文件的两种方式

Android实现打开本地pdf文件的两种方式

《Android实现打开本地pdf文件的两种方式》在现代应用中,PDF格式因其跨平台、稳定性好、展示内容一致等特点,在Android平台上,如何高效地打开本地PDF文件,不仅关系到用户体验,也直接影响... 目录一、项目概述二、相关知识2.1 PDF文件基本概述2.2 android 文件访问与存储权限2.
阅读更多...
使用Python实现全能手机虚拟键盘的示例代码

使用Python实现全能手机虚拟键盘的示例代码

《使用Python实现全能手机虚拟键盘的示例代码》在数字化办公时代,你是否遇到过这样的场景：会议室投影电脑突然键盘失灵、躺在沙发上想远程控制书房电脑、或者需要给长辈远程协助操作？今天我要分享的Pyth... 目录一、项目概述：不止于键盘的远程控制方案1.1 创新价值1.2 技术栈全景二、需求实现步骤一、需求
阅读更多...
Spring Shell 命令行实现交互式Shell应用开发

Spring Shell 命令行实现交互式Shell应用开发

《SpringShell命令行实现交互式Shell应用开发》本文主要介绍了SpringShell命令行实现交互式Shell应用开发,能够帮助开发者快速构建功能丰富的命令行应用程序,具有一定的参考价... 目录引言一、Spring Shell概述二、创建命令类三、命令参数处理四、命令分组与帮助系统五、自定义S
阅读更多...
SpringBatch数据写入实现

SpringBatch数据写入实现

《SpringBatch数据写入实现》SpringBatch通过ItemWriter接口及其丰富的实现,提供了强大的数据写入能力,本文主要介绍了SpringBatch数据写入实现,具有一定的参考价值,... 目录python引言一、ItemWriter核心概念二、数据库写入实现三、文件写入实现四、多目标写入
阅读更多...
Android Studio 配置国内镜像源的实现步骤

Android Studio 配置国内镜像源的实现步骤

《AndroidStudio配置国内镜像源的实现步骤》本文主要介绍了AndroidStudio配置国内镜像源的实现步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,... 目录一、修改 hosts，解决 SDK 下载失败的问题二、修改 gradle 地址，解决 gradle
阅读更多...
SpringSecurity JWT基于令牌的无状态认证实现

SpringSecurity JWT基于令牌的无状态认证实现

《SpringSecurityJWT基于令牌的无状态认证实现》SpringSecurity中实现基于JWT的无状态认证是一种常见的做法,本文就来介绍一下SpringSecurityJWT基于令牌的无... 目录引言一、JWT基本原理与结构二、Spring Security JWT依赖配置三、JWT令牌生成与
阅读更多...
resultMap如何处理复杂映射问题

resultMap如何处理复杂映射问题

《resultMap如何处理复杂映射问题》：本文主要介绍resultMap如何处理复杂映射问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录resultMap复杂映射问题Ⅰ 多对一查询：学生——老师Ⅱ 一对多查询：老师——学生总结resultMap复杂映射问题
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2