Come racchiudere una classe asincrona per renderla sincrona? Usa NSRunLoop?

Question

Attualmente sto lavorando ad un'applicazione per iPhone e ho una libreria di una terza parte che ha un comportamento asincrono, ma che mi piacerebbe racchiudere la mia classe e farla sembrare sincrona.

La classe centrale in questa libreria, chiamiamola classe Connection, ha diverse funzioni che risolvono il risultato finale quando vengono chiamati i metodi su un'istanza di una classe delegata. Quello che sto cercando di fare è racchiudere questa classe e delegare in modo che sembri sincrono anziché asincrono. Se lo facessi in Java, userei FutureTask o CountdownLatch o semplicemente join(). Ma non sono sicuro che sia il modo migliore per farlo nell'Obiettivo C.

Ho iniziato creando un estensore NSTreadread, NFCThread, che è conforme al protocollo delegato sopra menzionato. L'idea è che vorrei init e NFCThread, passare l'istanza NFCThread al metodo setDelegate di Connection, avviare il thread e quindi chiamare un metodo asincrono su Connection. La mia aspettativa è che uno dei tre metodi delegate sull'istanza NFCThread venga chiamato alla fine causando l'uscita del thread.

Per simulare un join ho fatto quanto segue. Ho aggiunto un NSConditionalLock a NFCThread:

joinLock = [[NSConditionLock alloc] initWithCondition:NO]; 

Il codice attorno alla chiamata a Connection sembra qualcosa di simile:

NFCThread *t = [[NFCThread alloc] init]; 
[connection setDelegate:t]; 
[t start]; 

[connection openSession]; 
// Process errors, etc... 

[t.joinLock lockWhenCondition:YES]; 
[t.joinLock unlock]; 
[t release]; 
[connection setDelegate:nil]; 

Il protocollo per il delegato ha tre metodi. In NFCThread ho implementato ogni metodo qualcosa di simile:

- (void)didReceiveMessage:(CommandType)cmdType 
        data:(NSString *)responseData 
       length:(NSInteger)length { 
    NSLog(@"didReceiveMessage"); 
    // Do something with data and cmdType... 
    [joinLock lock]; 
    [joinLock unlockWithCondition:YES]; 
    callBackInvoked = YES; 
} 

ho sovraccaricato il metodo principale di NFCThread in modo che solo loop continuo. Qualcosa di simile a questo:

while (!callBackInvoked) { ; } 

ho scoperto che questo non è davvero una buona idea, dal momento che provoca l'utilizzo della CPU di passare attraverso il tetto. Così, invece ho provato ad utilizzare un ciclo di esecuzione da parte di alcuni esempi che ho trovato su questo sito:

NSRunLoop *runLoop = [NSRunLoop currentRunLoop]; 
[runLoop addPort:[NSMachPort port] forMode:NSDefaultRunLoopMode]; 

while (!callBackInvoked) { 
    [runLoop runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]]; 
} 

In entrambi i miei implementazioni thread principale è sempre bloccato e sembra che nessuno dei metodi delegato vengono mai chiamati. Tuttavia, so che la libreria funziona correttamente e che normalmente vengono chiamate le chiamate ai metodi delegati.

Mi sento come se mi mancasse qualcosa di ovvio qui. Qualsiasi aiuto molto apprezzato.

Rich

Answer 1

Ok, quindi ci sono alcuni problemi diversi qui, sto cercando di pensare da dove cominciare.

Ma proprio così capiamo cosa stai cercando di realizzare, quando dici che vuoi che la chiamata "appaia" sincrona, vuoi dire che vuoi che la chiamata blocchi? Stai facendo questa chiamata dal thread principale?Se è così, sembra che tu stia bloccando il thread principale in base alla progettazione.

Ricordare che la libreria di terze parti sta probabilmente programmando eventi nel ciclo di esecuzione principale. Puoi creare il tuo ciclo di esecuzione ed eseguirlo in un altro thread, ma hai detto all'altra libreria di utilizzare quel ciclo di esecuzione per i suoi eventi? (Ad esempio, potrebbe fare richieste di rete asincrone pianificate nel ciclo di esecuzione principale che hai bloccato)

Vorrei ripensare a quello che stai facendo un po ', ma prima dovremmo sapere se la tua intenzione è per bloccare il thread da cui stai effettuando questa chiamata. Inoltre, devi supportare iPhoneOS 3.x?

Answer 2

Volete un semaforo, che permetterà il vostro percorsi di codice primario di bloccare fino a quando il callback asincroni segnala il semaforo e gli permette di continuare.

I semafori sono disponibili in iOS 4 tramite Grand Central Dispatch.

Sembra che il comportamento dei semafori possa essere implementato in iOS 3 con NSCondition.

Answer 3

Ho appena implementato qualcosa di simile. Il contesto era: - avvolgere diverse chiamate a ZipArchive in una discussione in background - per ogni chiamata da decomprimere, visualizzare un indicatore di avanzamento diverso (ruota che gira infinitamente con il nome del file da espandere) - eseguire un'operazione di pulizia quando tutte le gli archivi sono stati ampliati

Risulta NSConditionLock rende semplice, e il codice funziona come segue:

NSConditionLock* lock = alloc/init 
for(int idx = 0; idx < [list count]; idx++) { 
    NSString* fileName = ["getIdx's element in list"] 
    [cond lockWhenCondition:idx]; // 

    ... prepare things before forking 

    [cond unlockWithCondition:-1]; 
    [Notification forkBlock:^(void){ 
    [cond lockWhenCondition:-1]; 

    NSAutoreleasePool *pool = [alloc/init]; 
    [ZipArchive unzipFile:fileName]; 
    [pool release]; 
    [cond unlockWithCondition:idx+1]; 
    }]; 
} 

[cond lockWhenCondition:[list count]; 
// all the tasks are now completed 

Ciascuno dei blocchi sono in programma in un thread in background. La classe di notifica si occupa di animare l'UIView con la ruota che gira e di avvolgere il blocco in un'altra discussione. Lock/unlock deve essere chiamato dallo stesso thread, quindi la condizione è ciò che abilita il ping-pong tra i thread in background e in background (-1 per lo sfondo, 1,2,3..n per il foreground).

Answer 4

Quello che si vuole fare è usare NSCondition per attendere il thread corrente, e il segnale sul secondo thread per consentire al primo di continuare.

- (void) firstThread 
{ 
    workIsDone = NO; 
    //Start second thread here 
    [condition lock]; 
    while (!workIsDone) { 
     [condition wait]; 
    } 
    [condition unlock]; 

    // Keep going 
} 

- (void) secondThread 
{ 
    [condition lock]; 

    //Do some work. 
    workIsDone = YES; 
    [condition signal]; 
    [condition unlock]; 
}