同步生产者、消费者和生产者队列

Question

我有一个生产者和一个消费者。生产者将对象填充到其内部队列，消费者将这些对象一一取出。我想将消费者与生产者同步，以便消费者在没有准备好对象时阻塞，并且我想将生产者与其自身同步，以便当队列已满时它停止生产（并在有空间时重新开始） 。我该怎么做？我能够使用 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 被初始化为最大队列大小。到目前为止，这似乎有效，但上帝知道这是一种信心的行为，而不是坚定的信心。