Почему блок после dispatch_async(dispatch_get_main_queue() никогда не вызывается?
Я хочу выполнить некоторый код асинхронно и по этой причине начал использовать GCD для OSX/iOS.
В настоящее время я использую функцию dispatch_async ().
Когда я хочу выполнить что-то одновременно в другом потоке, я использую функцию dispatch_get_global_queue().
Когда я хочу отправить результат в основной поток, я использую функцию dispatch_get_main_queue().
Но результаты никогда не доходят до основного потока.
При установке точек останова в отладчике (в строках dispatch_async) блок после функции dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0) выполняется только иногда, но часто отладчик просто игнорирует его.
Когда блок исполняется и поток выполнения достигает точки останова в dispatch_async(dispatch_get_main_queue()), блок после этого всегда игнорируется.
Без dispatch_async(dispatch_get_global_queue) и dispatch_async(dispatch_get_main_queue) код выполняется должным образом, хотя и синхронно.
Мой вопрос заключается в том, почему dispatch_async(dispatch_get_main_queue() внутри блока dispatch_async (dispatch_get_global_queue()) никогда не выполняется?
И на той же ноте, почему блок dispatch_async (dispatch_get_global_queue() не выполняется каждый раз?
Моя среда разработки
ОС: OS X 10.11.3
IDE: Xcode 7.2
Компилятор: Apple LLVM версия 7.0.2 (clang-700.1.81)
Цель: x86_64-apple-darwin15.3.0
Вот простой пример, который воспроизводит ошибочное поведение (консольное приложение OS X):
TestClass.h
#ifndef TestClass_h
#define TestClass_h
@interface TestClass : NSObject {
}
- (void)testMethod:(NSString *)testString withCompletionBlock:(void(^)(NSString *blockResult, NSError __autoreleasing *error))completionBlock;
@end
#endif
TestClass.m
#import <Foundation/Foundation.h>
#import "TestClass.h"
@implementation TestClass
- (void)testMethod:(NSString *)testString withCompletionBlock:(void(^)(NSString *blockResult, NSError __autoreleasing *error))completionBlock {
__block NSString *stringResult = nil;
if (completionBlock) {
__block NSError *resultError = nil;
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
// THIS BLOCK IS CALLED ONLY SOMETIMES, MOST OF THE TIME IT IS IGNORED.
if ([testString isEqual: @"Error string"]) {
NSDictionary *errorUserInfo = @{ NSLocalizedDescriptionKey: @"This is an error.", NSLocalizedFailureReasonErrorKey: @"", NSLocalizedRecoverySuggestionErrorKey: @"" };
resultError = [[NSError alloc] initWithDomain:@"com.test.TestErrorDomain" code:10 userInfo:errorUserInfo];
}
else {
stringResult = testString;
}
dispatch_async(dispatch_get_main_queue(), ^{
// THIS BLOCK NEVER GETS EXECUTED.
completionBlock(stringResult, resultError);
});
});
}
}
@end
main.m
#import <Foundation/Foundation.h>
#import "TestClass.h"
int main(int argc, const char * argv[]) {
@autoreleasepool {
__block NSString *resultString = nil;
TestClass * testObject = [[TestClass alloc] init];
// Output for this call should be: The result string is: Test string.
[testObject testMethod:@"Test string" withCompletionBlock:^(NSString *blockString, NSError __autoreleasing *error) {
resultString = blockString;
if (resultString) {
NSLog(@"The result string is: %@.", resultString);
}
}];
// Output for this call should be: Error: This is an error.
[testObject testMethod:@"Error string" withCompletionBlock:^(NSString *blockString, NSError __autoreleasing *error) {
resultString = blockString;
if (!resultString) {
if (error) {
NSLog(@"Error: %@", [error localizedDescription]);
}
else {
NSLog(@"Error not recognized!");
}
}
}];
}
return 0;
}
2 ответа
Это связано с тем, что ваш объект TestClass освобождается сразу после выхода из функции main(). Будучи в основном асинхронным, testMethod: не блокирует указатель в main().
Попробуйте добавить семафор в конце main(). Этот семафор должен быть сигнализирован в методе testMethod dispatch_async(dispatch_get_main_queue(), ^{});
блок.
Вот рабочий пример с семафором, как предложено в ответе @CharlesThierry. Я также включил некоторые NSLogs, которые помогают проиллюстрировать поток выполнения:
TestClass.h
#ifndef TestClass_h
#define TestClass_h
@interface TestClass : NSObject {
}
- (void)testMethod:(NSString *)testString withSemaphore:(dispatch_semaphore_t)sem withCompletionBlock:(void(^)(NSString *blockResult, NSError __autoreleasing *error))completionBlock;
@end
#endif
TestClass.m
#import <Foundation/Foundation.h>
#import "TestClass.h"
@implementation TestClass
- (void)testMethod:(NSString *)testString withSemaphore:(dispatch_semaphore_t)sem withCompletionBlock:(void(^)(NSString *blockResult, NSError __autoreleasing *error))completionBlock {
__block NSString *stringResult = nil;
if (completionBlock) {
__block NSError *resultError = nil;
NSLog(@"INSIDE TEST METHOD, OUTSIDE DISPATCH ASYNC");
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
NSLog(@"INSIDE THE DISPATCH ASYNC TO THE GLOBAL QUEUE");
if ([testString isEqual: @"Error string"]) {
NSDictionary *errorUserInfo = @{ NSLocalizedDescriptionKey: @"This is an error.", NSLocalizedFailureReasonErrorKey: @"", NSLocalizedRecoverySuggestionErrorKey: @"" };
resultError = [[NSError alloc] initWithDomain:@"com.test.TestErrorDomain" code:10 userInfo:errorUserInfo];
}
else {
stringResult = testString;
}
dispatch_async(dispatch_get_main_queue(), ^{
NSLog(@"INSIDE THE DISPATCH ASYNC TO THE MAIN QUEUE!");
completionBlock(stringResult, resultError);
dispatch_semaphore_signal(sem);
});
});
}
}
@end
main.m
#import <Foundation/Foundation.h>
#import "TestClass.h"
int main(int argc, const char * argv[]) {
@autoreleasepool {
NSLog(@"BEFORE BLOCK");
__block NSString *resultString = nil;
TestClass * testObject = [[TestClass alloc] init];
dispatch_semaphore_t sem = dispatch_semaphore_create(0);
[testObject testMethod:@"Test string" withSemaphore:sem withCompletionBlock:^(NSString *blockString, NSError __autoreleasing *error)
{
NSLog(@"INSIDE FIRST BLOCK");
resultString = blockString;
if (resultString)
{
NSLog(@"The result string is: %@.", resultString);
}
}];
[testObject testMethod:@"Error string" withSemaphore:sem withCompletionBlock:^(NSString *blockString, NSError __autoreleasing *error)
{
NSLog(@"INSIDE SECOND BLOCK");
resultString = blockString;
if (!resultString)
{
if (error)
{
NSLog(@"Error: %@", [error localizedDescription]);
}
else
{
NSLog(@"Error not recognized!");
}
}
}];
NSLog(@"AFTER BLOCK!");
while (dispatch_semaphore_wait(sem, DISPATCH_TIME_NOW))
[[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode beforeDate:[NSDate dateWithTimeIntervalSinceNow:10]];
}
return 0;
}