|
|
|
@ -31,6 +31,28 @@ public class RedissonRingBufferTest extends RedisDockerTest {
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
|
public void testReSetCapacity() {
|
|
|
|
|
RRingBuffer<Integer> buffer = redisson.getRingBuffer("test");
|
|
|
|
|
buffer.trySetCapacity(3);
|
|
|
|
|
for (int i = 0; i < 3; i++) {
|
|
|
|
|
buffer.add(i);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
assertThat(buffer).containsExactly(0, 1, 2);
|
|
|
|
|
assertThat(buffer.size()).isEqualTo(3);
|
|
|
|
|
|
|
|
|
|
// new capacity greater than list's length, not trim
|
|
|
|
|
buffer.setCapacity(5);
|
|
|
|
|
assertThat(buffer).containsExactly(0, 1, 2);
|
|
|
|
|
assertThat(buffer.size()).isEqualTo(3);
|
|
|
|
|
|
|
|
|
|
// new capacity less than list's length, trim size to new capacity
|
|
|
|
|
buffer.setCapacity(1);
|
|
|
|
|
assertThat(buffer).containsExactly(2);
|
|
|
|
|
assertThat(buffer.size()).isEqualTo(1);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
|
public void testAdd() {
|
|
|
|
|
RRingBuffer<Integer> buffer = redisson.getRingBuffer("test");
|
|
|
|
|