我对我的应用程序中的 block 和同步性有疑问。这是场景:
我有一个 NetworkManager,它使用 AFHTTPRequestOperationManager (AFNetworking 2.0) 来调用服务器。我有一个 ContentStore 类单例,它为应用程序提供内容。应用程序中的任何类都可以向内容存储请求内容,它会传递一个 block 来接收该内容。如果 ContentStore 在内存或存档中有内容,它会将它传递给请求内容的类中的 block 。如果没有,它会向 NetworkManager 发出请求,并将一个 block 传递给 NetworkManager,当内容从服务器到达时,该 block 会调用原始类中的 block 。到目前为止,这一切都很好并且运作良好。
问题是有时类可以在已经为内容发出请求但尚未收到回复时调用 ContentStore 来获取内容。在这种情况下,两个请求会针对相同的内容发送到服务器,这实际上不会造成问题,但效率很低。
我想出了一个系统,该系统执行以下操作:如果正在向服务器请求内容,ContentStore 会将传递给它的所有 block 保存在一个数组中,当从服务器收到回复时 ContentStore循环遍历 block 数组并将内容传递给每个 block 。
这很好用,但我想知道是否有可能出现故障。当一个类为内容调用 ContentStore 并且请求正在进行时,是否可以在下面代码中的 downloadCompletionBlock 循环遍历同一数组时将 block 添加到数组中?
感谢所有花时间理解和回答我的问题的人。如果您需要更多信息,请告诉我。
@interface ContentStore()
@property (nonatomic, strong) NSDictionary *downloadDictionary;
@property (nonatomic, strong) NSMutableArray *downloadBlocksForRequest;
@property (nonatomic, strong) NetworkManger *networkManager;
@end
@implementation ContentStore
- (void) downloadWithCompletionBlock:(void (^)(NSDictionary *))completionBlock
{
if (_downloadDictionary) {
completionBlock(_downloadDictionary);
return;
} else {
_downloadDictionary = [NSKeyedUnarchiver unarchiveObjectWithFile:[self downloadArchivePath]];
if (_downloadDictionary) {
completionBlock(_downloadDictionary);
return;
} else if (_downloadBlocksForRequest) {
[_downloadBlocksForRequest addObject:completionBlock];
return;
} else {
_downloadBlocksForRequest = [[NSMutableArray alloc]init];
[_downloadBlocksForRequest addObject:completionBlock];
}
}
void (^downloadCompletionBlock)(NSDictionary *) = ^(NSDictionary *downloadDictionary)
{
// do other work necessary
[NSKeyedArchiver archiveRootObject:downloadDictionary toFile:[self downloadArchivePath]];
[self setDownloadDictionary:downloadDictionary];
for (int i=0; i<_facesBlocksForRequest.count; i++) {
void (^complBlock)(NSDictionary *) = [_facesBlocksForRequest objectAtIndex:i];
complBlock(downloadDictionary);
}
_downloadBlocksForRequest = nil;
};
[_networkManager downloadWithCompletionBlock:downloadCompletionBlock];
}
最佳答案
NSMutableArray,与 iOS 中的大多数(如果不是全部)可变容器一样,是 not thread-safe .所以你的担心是有道理的,这段代码可能会引入一个非常难以捕捉的错误。您可能希望通过执行以下操作来同步对它的访问
@synchronized(_downloadBlocksForRequest) {
// enumerate _downloadBlocksForRequest, or add an object to it, etc.
}
关于iOS block 和同步性,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20616959/
文章目录一、概述简介原理模块二、配置Mysql使用版本环境要求1.操作系统2.mysql要求三、配置canal-server离线下载在线下载上传解压修改配置单机配置集群配置分库分表配置1.修改全局配置2.实例配置垂直分库水平分库3.修改group-instance.xml4.启动监听四、配置canal-adapter1修改启动配置2配置映射文件3启动ES数据同步查询所有订阅同步数据同步开关启动4.验证五、配置canal-admin一、概述简介canal是Alibaba旗下的一款开源项目,Java开发。基于数据库增量日志解析,提供增量数据订阅&消费。Git地址:https://github.co
类似的问题,但对于java,Keepingi18nresourcessynced如何保持i18nyamllocals的key同步?即,当将key添加到en.yml时,如何将它们添加到nb.yml或ru.yml?如果我在my_title:"atitle"旁边添加键my_label:"sometextinenglish"我想把它给我的其他本地人我指定,因为我不能做所有的翻译,它应该回到其他语言的英语例如en.ymlsomegroup:my_tile:"atitleinenglish"my_label:"sometextinenglish"othergroup:...我想发出命令,将整个键和
目录FIFO一.自定义同步FIFO1.1代码设计1.2Testbech1.3行为仿真***学习位宽计算函数$clog2()***$clog2()系统函数使用,可以不关注***分布式资源或者BLOCKBRAM二.异步FIFO2.1在FIFO判满的时候有两种方式:2.2异步FIFO为什么要使用格雷码2.2.1介绍格雷码2.2.2格雷码在异步FIFO中的应用2.2.2格雷码判满2.4二进制与格雷码之间的转换2.4.1二进制码转换为格雷码的方法2.4.2格雷码转换为二进制码的方法2.3实现框图2.5实现及仿真代码2.6仿真图验证2.7结论FIFO 这篇更多的是记录FIFO学习,参考了众多优秀的文章,
数据同步的方式数据同步的2大方式基于SQL查询的CDC(ChangeDataCapture):离线调度查询作业,批处理。把一张表同步到其他系统,每次通过查询去获取表中最新的数据。也就是我们说的基于SQL查询抽取;无法保障数据一致性,查的过程中有可能数据已经发生了多次变更;不保障实时性,基于离线调度存在天然的延迟;工具软件以Kettle(ApacheHop最新版)、DataX为代表,需要结合任务调度系统使用。基于日志的CDC:实时消费日志,流处理,例如MySQL的binlog日志完整记录了数据库中的变更,可以把binlog文件当作流的数据源;保障数据一致性,因为binlog文件包含了所有历史变更
IGH主站通信测试linuxcnc配置基础机器人控制LinuxCNC与EtherCAT介绍&&PDO&SDO,搭建环境步骤需要配置IGH主站的查看这篇文章linux系统学习笔记7——一次性安装igh-ethercat主站CSP模式DC同步方式preemrt实时补丁直接上代码,这部分是直接控制使用csp模式控制一个从站运动使能后直接运动,10s,每秒607a(目标位置)增加100.注意:急停按下ESC代码分为两部分,一个是通信线程主要负责和伺服通信,使能伺服,读取和写入寄存器值。第二个是操作线程,负责修改位置的值,和监控按键。使用此代码,首先根据手册1.修改PDO条目,要和自己的伺服一致2.修改
为什么新的JavaScript模块request同步?它应该只用于作业队列吗?有什么方法可以在ArangoDB中发出异步http(s)请求吗? 最佳答案 完全披露:我是ArangoDB开发团队的一员,主要从事Foxx和所有JavaScript方面的工作。我也是写org/arangodb/request的人模块。ArangoDB是一个不同于Node.js的环境,尽管有许多相似之处(例如使用V8JavaScript引擎)。与Node.js(或浏览器)不同,ArangoDB使用基于线程的并发模型并且没有事件循环。然而,线程并没有在Java
我有两个关于Firebasewebplatform的相关问题的synchronisationoflocally-modifieddatatotheserver:EveryclientsharingaFirebasedatabasemaintainsitsowninternalversionofanyactivedata.Whendataisupdatedorsaved,itiswrittentothislocalversionofthedatabase.TheFirebaseclientthensynchronizesthatdatawiththeFirebaseserversandw
我有需要同步工作的promise对象。例如,第二个promise不应该在第一个promise完成之前起作用。如果第一个拒绝第一个必须再次执行。我已经实现了一些示例。这个效果很好。调用getVal,等待2000ms,返回,i++,再次调用getVal.....getVal(){returnnewPromise(function(resolve,reject){setTimeout(function(){resolve(19)},2000);});}asyncpromiseController(){for(vari=0;i但我需要控制一组promise对象。我想做的是我有一个数据,我把它分
我编写了一个JavaScript函数,它使用XmlHttpRequest异步调用Web服务。我被要求让这个函数在页面呈现之前完成它的工作。我想我可以使AJAX请求同步,但我不希望这使页面挂起太久-如果未收到响应,我想在1秒后中止请求。是否可以中止同步XmlHttpRequest? 最佳答案 你不能:http://www.hunlock.com/blogs/Snippets:_Synchronous_AJAX说:“同步AJAX(真正的SJAX——同步Javascript和XML)是模态的,这意味着javascript将停止处理您的程序
是否有任何同步原语,如障碍、信号量、锁、监视器,...JavaScript/WebWorkers或者是否有一些可用的库使我能够使用这些东西(我正在考虑Java中的java.util.concurrent之类的东西)?Worker是否具有将它们与线程区分开来的晦涩属性(例如,它们可以与主线程共享内存)?是否有某种限制可以产生多少worker(例如,出于安全原因或其他原因......)?我需要特别注意什么吗? 最佳答案 网络worker没有共享内存的概念;复制线程之间传递的所有消息。话虽如此,您没有屏障、信号量、锁和监视器,因为您在网络