Synchronizuj zagnieżdżone zadanie asynchroniczne

Question

Mam zagnieżdżone zadania asynchroniczne. Funkcja poniżej następującego po niej przepływu: loadEpisodes (załaduj listę odcinków) -> użyj tablicy od zakończenia, aby przejrzeć każdy odcinek pierwszy i załaduj komentarze (jeszcze jedno zadanie asynchroniczne) dla określonego odcinka.

Problem polega na: comletion (fullEpisodes) sprawdzony przed zakończeniem zadania ładowania komentarzy. Próbowałem użyć Dispatch Group (drugi blok kodu), ale to nie działa.

func loadComments(comletion: @escaping ([Episode]) -> Void){ 
loadEpisodes(completion: { 
    episodes in 
    var fullyEpisodes = [Episode]() 
    for episode in episodes { 
     WebService().load(resource: episode.comment, comletion: { 
      comments in 
      if let comments = comments { 
       let _episode = Episode(id: episode.id, title: episode.title, comments: comments) 
       fullyEpisodes.append(_episode) 
       print("done") 
      } 
     }) 
    } 
    comletion(fullyEpisodes) 

}) 
} 

Zaimplementowane Wysłanie Grupa:

func loadComments(comletion: @escaping ([Episode]) -> Void){ 
    loadEpisodes(completion: { 
     episodes in 
     var fullyEpisodes = [Episode]() 
     let group = DispatchGroup() 
     for episode in episodes { 
      group.enter() 
      WebService().load(resource: episode.comment, comletion: { 
       comments in 
       if let comments = comments { 
        let _episode = Episode(id: episode.id, title: episode.title, comments: comments) 
        fullyEpisodes.append(_episode) 
        print("done") 
       } 
      }) 
      group.leave() 
     } 
     group.wait() 
     group.notify(queue: .main, execute: { 
      comletion(fullyEpisodes) 
     }) 

    }) 
} 

Kiedy próbuję zastąpić żądania obciążenia komentarz przez „print (” coś „)” (nie nowe zadanie asynchroniczne), grupa Wysłanie działa.

Answer 1

W swoim drugim przykładzie (a) przenieś group.leave() do zamknięcia obsługi zakończenia realizacji ; i (b) całkowicie usunąć group.wait().

func loadComments(comletion: @escaping ([Episode]) -> Void){ 
    loadEpisodes(completion: { 
     episodes in 
     var fullyEpisodes = [Episode]() 
     let group = DispatchGroup() 
     for episode in episodes { 
      group.enter() 
      WebService().load(resource: episode.comment, comletion: { 
       comments in 
       if let comments = comments { 
        let _episode = Episode(id: episode.id, title: episode.title, comments: comments) 
        fullyEpisodes.append(_episode) 
        print("done") 
       } 
       group.leave() 
      }) 
      // group.leave() 
     } 
     //group.wait() 
     group.notify(queue: .main, execute: { 
      comletion(fullyEpisodes) 
     }) 

    }) 
} 

lub czyszczenia, że ​​się trochę ze spływu składni zamykania i mocowania completion pisowni:

func loadComments(completion: @escaping ([Episode]) -> Void) { 
    loadEpisodes { episodes in 
     var fullyEpisodes = [Episode]() 
     let group = DispatchGroup() 
     for episode in episodes { 
      group.enter() 
      WebService().load(resource: episode.comment) { comments in 
       if let comments = comments { 
        let _episode = Episode(id: episode.id, title: episode.title, comments: comments) 
        fullyEpisodes.append(_episode) 
       } 
       group.leave() 
      } 
     } 
     group.notify(queue: .main) { 
      completion(fullyEpisodes) 
     } 
    } 
}