0

我对生产者消费者配方如何与Zookeeper一起工作没有疑问。动物园管理员生产者消费者

到目前为止,我所见过的所有例子都有与独立线程相同的java进程中的生产者和消费者。但是分发的重点是要有不同的生产者和消费者的实例(多个)。

具有不同的生产者和消费者实例意味着没有本地锁(syntonization)将有任何用处。

此外,因为多个进程正在观察相同的根队列节点,它们都将开始处理特定的传入条目。

我在这里得到错误?

+0

很难说出你在这里问的问题。也许指向一个具体的例子/配方,并提出有关问题。 Zookeeper的工作(的确是专为)多个进程。 – sbridges 2013-05-14 03:41:14

+0

@桥梁如果我在那里含糊不清,谢谢你和appologies。正如我们在Java链接阻塞队列中所看到的,take()方法在从队列中出队之前采用lock/gaurds尾节点。所以没有2个线程会从尾部获取同一个节点。在动物园管理员的情况下,观察队列根节点的所有进程都将得到通知,并且他们都可以抓取同一组节点并开始处理相同的节点。 – 2013-05-15 06:22:40

+0

@sbridges那么我怎样才能称此为分布式队列呢。我正在谈论Zookeeper的生产者消费者reciepe。 http://zookeeper.apache.org/doc/r3.4.1/zookeeperTutorial.html#sc_producerConsumerQueues – 2013-05-15 06:24:23

回答