如何在apache上实现消费者-生产者点燃队列?

Question

我知道ignite缓存确实提供了一个连续查询函数来允许事件触发函数。但是点燃队列呢?我们如何在点燃队列上实现生产者-消费者模型?例如，生产者将对象放入队列中，然后消费者通过queue.onAdd(function to do something)或queue.onRemove(function to do something)等方式处理该对象。

Answer 1

你不能把它作为阻塞队列使用吗?

制作人:

IgniteQueue<Object> queue = ignite.queue("myQueue", 0, new CollectionConfiguration());
queue.put("obj");

消费者:

for(;;)
System.out.println(queue.take());