tests fixed

pull/3048/head
Nikita Koksharov 4 years ago
parent e7eecb5da5
commit 3c1ac6af46

@ -63,7 +63,7 @@ public class RedissonTransferQueueTest extends BaseTest {
long time = System.currentTimeMillis();
queue.transfer(3);
assertThat(takeExecuted.get()).isTrue();
assertThat(System.currentTimeMillis() - time).isGreaterThan(2950);
assertThat(System.currentTimeMillis() - time).isGreaterThan(2850);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}

@ -51,7 +51,7 @@ public class RedissonBlockingDequeRxTest extends BaseRxTest {
RBlockingDequeRx<String> blockingDeque = redisson.getBlockingDeque("blocking_deque");
long start = System.currentTimeMillis();
String redisTask = sync(blockingDeque.pollLastAndOfferFirstTo("deque", 1, TimeUnit.SECONDS));
assertThat(System.currentTimeMillis() - start).isBetween(950L, 1110L);
assertThat(System.currentTimeMillis() - start).isBetween(950L, 1150L);
assertThat(redisTask).isNull();
}

Loading…
Cancel
Save