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。

相关文章

C++使用栈实现括号匹配的代码详解

C++使用栈实现括号匹配的代码详解

《C++使用栈实现括号匹配的代码详解》在编程中,括号匹配是一个常见问题,尤其是在处理数学表达式、编译器解析等任务时,栈是一种非常适合处理此类问题的数据结构,能够精确地管理括号的匹配问题,本文将通过C+... 目录引言问题描述代码讲解代码解析栈的状态表示测试总结引言在编程中，括号匹配是一个常见问题，尤其是在
阅读更多...
Java实现检查多个时间段是否有重合

Java实现检查多个时间段是否有重合

《Java实现检查多个时间段是否有重合》这篇文章主要为大家详细介绍了如何使用Java实现检查多个时间段是否有重合,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录流程概述步骤详解China编程步骤1：定义时间段类步骤2：添加时间段步骤3：检查时间段是否有重合步骤4：输出结果示例代码结语作
阅读更多...
使用C++实现链表元素的反转

使用C++实现链表元素的反转

《使用C++实现链表元素的反转》反转链表是链表操作中一个经典的问题,也是面试中常见的考题,本文将从思路到实现一步步地讲解如何实现链表的反转,帮助初学者理解这一操作,我们将使用C++代码演示具体实现,同... 目录问题定义思路分析代码实现带头节点的链表代码讲解其他实现方式时间和空间复杂度分析总结问题定义给定
阅读更多...
Java覆盖第三方jar包中的某一个类的实现方法

Java覆盖第三方jar包中的某一个类的实现方法

《Java覆盖第三方jar包中的某一个类的实现方法》在我们日常的开发中,经常需要使用第三方的jar包,有时候我们会发现第三方的jar包中的某一个类有问题,或者我们需要定制化修改其中的逻辑,那么应该如何... 目录一、需求描述二、示例描述三、操作步骤四、验证结果五、实现原理一、需求描述需求描述如下：需要在
阅读更多...
如何使用Java实现请求deepseek

如何使用Java实现请求deepseek

《如何使用Java实现请求deepseek》这篇文章主要为大家详细介绍了如何使用Java实现请求deepseek功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1.deepseek的api创建2.Java实现请求deepseek2.1 pom文件2.2 json转化文件2.2
阅读更多...
python使用fastapi实现多语言国际化的操作指南

python使用fastapi实现多语言国际化的操作指南

《python使用fastapi实现多语言国际化的操作指南》本文介绍了使用Python和FastAPI实现多语言国际化的操作指南,包括多语言架构技术栈、翻译管理、前端本地化、语言切换机制以及常见陷阱和... 目录多语言国际化实现指南项目多语言架构技术栈目录结构翻译工作流1. 翻译数据存储2. 翻译生成脚本
阅读更多...
C++初始化数组的几种常见方法(简单易懂)

C++初始化数组的几种常见方法(简单易懂)

《C++初始化数组的几种常见方法(简单易懂)》本文介绍了C++中数组的初始化方法,包括一维数组和二维数组的初始化,以及用new动态初始化数组,在C++11及以上版本中,还提供了使用std::array... 目录1、初始化一维数组1.1、使用列表初始化（推荐方式）1.2、初始化部分列表1.3、使用std::
阅读更多...
如何通过Python实现一个消息队列

如何通过Python实现一个消息队列

《如何通过Python实现一个消息队列》这篇文章主要为大家详细介绍了如何通过Python实现一个简单的消息队列,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录如何通过 python 实现消息队列如何把 http 请求放在队列中执行1. 使用 queue.Queue 和 reque
阅读更多...
Python如何实现PDF隐私信息检测

Python如何实现PDF隐私信息检测

《Python如何实现PDF隐私信息检测》随着越来越多的个人信息以电子形式存储和传输,确保这些信息的安全至关重要,本文将介绍如何使用Python检测PDF文件中的隐私信息,需要的可以参考下... 目录项目背景技术栈代码解析功能说明运行结php果在当今，数据隐私保护变得尤为重要。随着越来越多的个人信息以电子形
阅读更多...
使用 sql-research-assistant进行 SQL 数据库研究的实战指南(代码实现演示)

使用 sql-research-assistant进行 SQL 数据库研究的实战指南(代码实现演示)

《使用sql-research-assistant进行SQL数据库研究的实战指南(代码实现演示)》本文介绍了sql-research-assistant工具,该工具基于LangChain框架,集... 目录技术背景介绍核心原理解析代码实现演示安装和配置项目集成LangSmith 配置（可选）启动服务应用场景
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2