Синхронизация производителя, потребителя и очереди производителя

Question

У меня есть производитель и потребитель. Производитель заполняет свою внутреннюю очередь объектами, а потребитель получает эти объекты один за другим. Я хочу синхронизировать cosumer с производителем, чтобы потребитель блокировал, когда нет готовых объектов, и я хочу синхронизировать производителя с самим собой, чтобы он прекратил производство, когда очередь заполнена (и запускается снова, когда есть место) , Как я могу это сделать? Мне удалось решить более простой случай без очереди, используя NSConditionalLock, но с этой задачей проблема выглядит более сложной.

Answer 1

Вы можете рассмотреть возможность использования пары NSOperationQueues или очередей отправки. Ваши производственные операции (в очереди производителей) отправляют сообщения в главном потоке, если необходимо, объекту, который добавляет операции потребления в очередь потребителей.

Answer 2

Я использовал два семафора, objectsReady и 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

bufferFreeSlots инициализируется до максимального размера очередиПока что это работает, но Бог знает, что это акт веры, а не уверенность в себе.