Synchronisierung mehrerer Tasks auf einem einzelnen Thread

Question

Wie kann verhindert werden, dass wiederholt auf einen Codeblock von demselben Thread zugegriffen wird?

Angenommen, ich habe den nächsten Code:

func sendAnalytics() { 
    // some synchronous work 

    asyncTask() { _ in 
     completion() 
    } 
} 

Ich mag jeden Thread aus dem Zugriff auf "// einige synchrone Arbeit", zu verhindern, vor der Fertigstellung genannt wurde.

scheinen nur den Zugriff auf diesen Code aus mehreren Threads zu verhindern und speichern Sie mich nicht vom Zugriff auf diesen Code aus dem einzelnen Thread. Gibt es eine Möglichkeit, dies richtig zu tun, ohne benutzerdefinierte Lösungen zu verwenden?

Mein wiederholt Zugriff, ich meine, diese sendAnalytics aus einem Thread mehrmals aufrufen. Nehmen wir an, ich habe eine für, wie folgt aus:

for i in 0...10 { 
    sendAnalytics() 
} 

Jeder nächste Anruf wird nicht für die Fertigstellung warten innerhalb sendAnalytics aufgerufen (offensichtlich). Gibt es eine Möglichkeit, die nächsten Anrufe warten zu lassen, bevor der Abschluss ausgelöst wird? Oder die ganze Art zu denken ist falsch und ich muss dieses Problem höher lösen, am Körper?

Answer 1

Sie können eine DispatchSemaphore verwenden, um sicherzustellen, dass ein Aufruf abgeschlossen ist, bevor der nächste

let semaphore = DispatchSemaphore(value:1) 

func sendAnalytics() { 
    self.semaphore.wait() 
    // some synchronous work 

    asyncTask() { _ in 
     completion() 
     self.semaphore.signal() 
    } 
} 

Der zweite Aufruf von sendAnalytics blockiert, bis der erste AsyncTask abgeschlossen ist starten. Sie sollten darauf achten, die Hauptwarteschlange nicht zu blockieren, da Ihre App dadurch nicht mehr reagiert. Es ist wahrscheinlich sicherer, die sendAnalytics Anruf auf seine eigene Serien Absende-Warteschlange zu versenden, dieses Risiko zu beseitigen:

let semaphore = DispatchSemaphore(value:1) 
let analyticsQueue = DispatchQueue(label:"analyticsQueue") 

func sendAnalytics() { 
    analyticsQueue.async { 
     self.semaphore.wait() 
     // some synchronous work 

     asyncTask() { _ in 
      completion() 
      self.semaphore.signal() 
     } 
    } 
}