Synchronisation du producteur, du consommateur et de la file d'attente du producteur

Question

J'ai un producteur et un consommateur. Le producteur remplit sa file d'attente interne avec des objets, le consommateur prend ces objets un par un. Je veux synchroniser le cosommateur avec le producteur, de sorte que le consommateur bloque quand il n'y a pas d'objets prêts, et je veux synchroniser le producteur avec lui-même, afin qu'il cesse de produire quand la file est pleine (et recommence quand il y a de l'espace) . Comment je fais ça? J'ai été capable de résoudre un cas plus simple sans la file d'attente en utilisant NSConditionalLock, mais avec la file d'attente le problème semble plus complexe.

Answer 1

I a fini en utilisant deux sémaphores, objectsReady et bufferFreeSlots:

@implementation Producer 

- (id) getNextObject { 
    [objectsReady wait]; 
    id anObject = [[buffer objectAtIndex:0] retain]; 
    [buffer removeObjectAtIndex:0]; 
    [bufferFreeSlots signal]; 
    return [anObject autorelease]; 
} 

- (void) decodeLoop { 
    while (1) { 
     [bufferFreeSlots wait]; 
     [buffer push:[self produceAnObject]]; 
     [objectsReady signal]; 
    } 
} 

@end 

Le bufferFreeSlots est initialisé à la taille maximale de file d'attente. Jusqu'à présent, cela semble fonctionner, mais Dieu sait que c'est un acte de foi, pas une confiance solide.

Answer 2

Vous pouvez envisager d'utiliser une paire de NSOperationQueues ou des files d'attente d'envoi. Demandez à vos opérations de production (dans la file d'attente du producteur) d'envoyer des messages, sur le thread principal si nécessaire, à un objet qui ajoute des opérations de consommation à la file d'attente client.