我必须运行method
与block
, for loop
内部几次。我还必须等到所有的blocks
执行完成。
我的问题是我不明白我做错了什么,这导致我的整个应用程序冻结。下面是代码:
dispatch_semaphore_t semaphore = dispatch_semaphore_create(0);//1 - creating semaphore
for(int i = 0; i< myObj.count; i++){
[[DataManager shared] verifyObjectId:myObj[i].id
completionBlock:^(BOOL found) {
if(found){
//code here
dispatch_semaphore_signal(semaphore);//3 - signaling semaphore to continue
}
}];
dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);//2 - getting semaphore to wait
}
//I want to continue once all DB checks complete
现在,我不明白,为什么semaphore
不释放,for loop
不继续。
我真正需要的是,semaphore
在所有DB检查完成后释放。理想情况下,我希望semaphore
在for loop
之外等待。对如何做到这一点有什么建议吗?
编辑:解决方案:(基于接受的答案)
// create a group
dispatch_group_t group = dispatch_group_create();
for(int i = 0; i< myObj.count; i++){
// pair a dispatch_group_enter for each dispatch_group_leave
dispatch_group_enter(group);
[[DataManager shared] verifyObjectId:myObj[i].id
completionBlock:^(BOOL found) {
if(found){
//code here
}
dispatch_group_leave(group); //1 leave
}];
//Get a notification on a block that will be scheduled on the specified queue
dispatch_group_notify(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_HIGH, 0), ^{
NSLog(@"-all done!-");
//code here
});
}
如果无法访问verifyObjectid:completiongBlock:
,则存在几个问题。首先,只有在found
为真时才调用dispatch_semaphore_signal
。如果found
都是false,就会死锁。这可能只是一个转录错误,你的实际代码可能不会这样做。
另一种猜测是完成块被提交到当前运行的队列(主队列?)如果这是真的,那么这肯定是一个死锁,因为您永远不会运行dispatch_semaphore_signal
,因为它正在等待dispatch_semaphore_wait
。没有DataManager
的信息我不能告诉你。
您的方法也序列化调用,而我认为您希望它们是并行的。每个调用都必须等待前一个调用在代码中完成。
这里使用的更好的工具是dispatch_apply
和dispatch_group
。像这样(未经测试):
dispatch_group_t group = dispatch_group_create();
dispatch_apply(myObj.count, dispatch_get_global_queue(0, 0), ^(size_t i){
dispatch_group_enter(group);
[[DataManager shared] verifyObjectId:myObj[i].id
completionBlock:^(BOOL found) {
if(found){
//code here
}
dispatch_group_leave(group));
}];
});
dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
dispatch_apply
将不会返回,直到所有的块已经完成运行,这意味着dispatch_group_enter
已经运行了"count"次。然后使用dispatch_group_wait
等待对dispatch_group_leave
的所有调用。