|
|
@ -142,7 +142,7 @@ public class RedissonPriorityDeque<V> extends RedissonPriorityQueue<V> implement
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public RFuture<V> pollLastAsync() {
|
|
|
|
public RFuture<V> pollLastAsync() {
|
|
|
|
long threadId = Thread.currentThread().getId();
|
|
|
|
final long threadId = Thread.currentThread().getId();
|
|
|
|
final RPromise<V> result = new RedissonPromise<V>();
|
|
|
|
final RPromise<V> result = new RedissonPromise<V>();
|
|
|
|
lock.lockAsync(threadId).addListener(new FutureListener<Void>() {
|
|
|
|
lock.lockAsync(threadId).addListener(new FutureListener<Void>() {
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|