BlockingQueue.peek race-condition fixed. #106

pull/236/head
Nikita 10 years ago
parent 4ffd260b6c
commit 5018a3c31c

@ -88,10 +88,7 @@ public class RedissonQueue<V> extends RedissonList<V> implements RQueue<V> {
@Override @Override
public V peek() { public V peek() {
if (isEmpty()) { return getValue(0);
return null;
}
return get(0);
} }
@Override @Override

Loading…
Cancel
Save