[Hazelcast系列 五] 分布式queue
Hazelcast queue是java.util.concurrent.BlockingQueue 的分布式实现，Hazelcast的queue允许集群所有成员和其交互。使用Hazelcast的分布式queue，可以一个成员添加元素，另外的成员移除元素。
7.3.1. 获取一个队列并向队列添加元素
使用Hazelcast实例的getQueue 获得一个queue，并调用queue的put 方法向队列添加元素。
HazelcastInstance instance = Hazelcast.newHazelcastInstance();
IQueue<Integer> queue = instance.getQueue("data");
queue.put(1);
Integer item = queue.take();
System.out.println(item);
boolean offerResult = queue.offer(2,1, TimeUnit.SECONDS);
System.out.println(offerResult);
Integer nextItem = queue.poll(1,TimeUnit.SECONDS);
System.out.println(nextItem);
相关文章