Warten Sie, bis mehrere AFNetworking-Anforderungen abgeschlossen sind.

Question

Ich muss warten, bis mehrere AFNetworking-Anforderungen abgeschlossen sind. Ich habe versucht, Dispatch-Gruppen zu verwenden, aber ich kann es scheinbar nicht richtig machen.

Hier ist mein Code:

dispatch_group_t group = dispatch_group_create(); 

for (int k = 0; k < 10 ; k++) { 
    dispatch_group_enter(group); 

    [[AFHTTPSessionManager manager] GET:@"http://google.com/" parameters:nil progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id _Nullable responseObject) { 
     NSLog(@"success"); 
     dispatch_group_leave(group); 
    } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) { 
     NSLog(@"failure"); 
     dispatch_group_leave(group); 
    }]; 
} 

dispatch_group_wait(group, DISPATCH_TIME_FOREVER); 

NSLog(@"DONE"); 

Das Problem ist, dass es auf dispatch_group_wait stecken bleibt, weil weder der Erfolg Block, noch die Fehlerblöcke genannt werden.

Wie kann ich es lösen?

Answer 1

Die Absende-Warteschlange für completionBlock. Wenn NULL (Standard), wird die Hauptwarteschlange verwendet.

dispatch_group_t group = dispatch_group_create(); 

dispatch_queue_t queue = dispatch_queue_create("com.app", DISPATCH_QUEUE_CONCURRENT); 

AFHTTPSessionManager *manager = [AFHTTPSessionManager manager]; 
manager.completionQueue = queue; 
for(int k = 0; k < 10; k++) { 
    dispatch_group_enter(group); 

    dispatch_async(queue, ^{ 
     NSLog(@"%d", k); 
     [manager GET:@"http://baidu.com/" parameters:nil progress:nil success:^(NSURLSessionDataTask *_Nonnull task, id _Nullable responseObject) { 
      NSLog(@"success"); 
      dispatch_group_leave(group); 
     } failure:^(NSURLSessionDataTask *_Nullable task, NSError *_Nonnull error) { 
      NSLog(@"failure"); 
      dispatch_group_leave(group); 
     }]; 
    }); 
} 

dispatch_group_wait(group, DISPATCH_TIME_FOREVER); 

NSLog(@"DONE"); 

Answer 2

die Sie interessieren,

dispatch_group_t group = dispatch_group_create(); 

for (int k = 0; k < 10 ; k++) { 
    dispatch_group_enter(group); 

    [[AFHTTPSessionManager manager] GET:@"http://google.com/" parameters:nil progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id _Nullable responseObject) { 
     NSLog(@"success"); 
     dispatch_group_leave(group); 
    } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) { 
     NSLog(@"failure"); 
     dispatch_group_leave(group); 
    }]; 
} 

dispatch_group_notify(group, dispatch_get_main_queue(), ^{ 

    NSLog(@"All done"); 

}); 

dispatch_group_notify wird aufgerufen, wenn alle Aufgaben abgeschlossen wird.

Answer 3

Sie können PromiseKit verwenden. Sehr leistungsfähig.

Sequential

 [self.manager GET:@"http://www.error-url.ss/" parameters:nil].then(^(id responseObject, AFHTTPRequestOperation *operation){ 
     NSLog(@"first request completed for operation: %@", operation.request.description); 
     return [self.manager GET:@"http://www.apple.com" parameters:nil]; 
    }).then(^{ 
     NSLog(@"second request completed"); 
    }).catch(^(NSError *error){ 
     NSLog(@"error happened: %@", error.localizedDescription); 
     NSLog(@"original operation: %@", error.userInfo[AFHTTPRequestOperationErrorKey]); 
    }); 

OR (wie pro Ihre Anforderung)

 [PMKPromise when:@[ 
         [self.operationManager GET:@"ip" parameters:nil].then(^(){numberOfOperationsCompleted ++;}), 
         [self.operationManager GET:@"get" parameters:nil].then(^(){numberOfOperationsCompleted ++;}) 
         ]].then(^(){ 
     //do something when all operations are finished 
    }); 

Answer 4

Sie können diese Hilfsfunktion verwenden, um den Hauptthread zu blockieren.

static inline void hxRunInMainLoop(void(^block)(BOOL *done)) { 
__block BOOL done = NO; 
block(&done); 
while (!done) { 
    [[NSRunLoop mainRunLoop] runUntilDate: [NSDate dateWithTimeIntervalSinceNow:.1]]; 
} 
} 

Sie müssen auch einen Zähler implementieren und bei Erfolg oder Misserfolg erhöhen.

- (void)test { 
    __block int count = 0; 

    hxRunInMainLoop(^(BOOL *done) { 

    for (int i = 0; i < 10; i++) { 

    [AFHTTPSessionManager manager] GET:@"http://google.com/" parameters:nil progress:nil success:^(NSURLSessionDataTask * _Nonnull task, id _Nullable responseObject) { 
     NSLog(@"success"); 
     count++; 
     if (count == 9) { 
     *done = YES; 
     } 
    } failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) { 
     NSLog(@"failure"); 
     count++; 
     if (count == 9) { 
     *done = YES; 
     } 
    }]; 
} 

Dies blockiert den Hauptthread, bis done auf YES gesetzt ist.