Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package org.mapdb;
 
 
 import org.junit.Test;
 
 import java.io.File;
 import java.util.Queue;
 
 import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;
public class QueuesTest {
    @Test public void stack_persisted(){
        File f = Utils.tempDbFile();
        DB db = DBMaker.newFileDB(f).transactionDisable().cacheDisable().asyncWriteDisable().make();
        Queue<Objectstack = db.getStack("test");
        stack.add("1");
        stack.add("2");
        stack.add("3");
        stack.add("4");
        db.close();
        stack = db.getStack("test");
        assertEquals("4",stack.poll());
        assertEquals("3",stack.poll());
        assertEquals("2",stack.poll());
        assertEquals("1",stack.poll());
        assertNull(stack.poll());
        db.close();
    }
    @Test public void queue_persisted(){
        File f = Utils.tempDbFile();
        DB db = DBMaker.newFileDB(f).transactionDisable().cacheDisable().asyncWriteDisable().make();
        Queue<Objectqueue = db.getQueue("test");
        queue.add("1");
        queue.add("2");
        queue.add("3");
        queue.add("4");
        db.close();
        queue = db.getQueue("test");
        assertEquals("1"queue.poll());
        assertEquals("2"queue.poll());
        assertEquals("3"queue.poll());
        assertEquals("4"queue.poll());
        assertNull(queue.poll());
        db.close();
    }
    @Test public void circular_queue_persisted(){
        //i put disk limit 4 objects ,
        File f = Utils.tempDbFile();
        DB db = DBMaker.newFileDB(f).transactionDisable().cacheDisable().asyncWriteDisable().make();
        Queue queue = db.createCircularQueue("test",null, 4);
        //when i put 6 objects to queue
        queue.add(0);
        queue.add(1);
        queue.add(2);
        queue.add(3);
        //now deletes 0 on first
        queue.add(4);
        //now deletes 1
        queue.add(5);
        db.close();
        queue = db.getCircularQueue("test");
        assertEquals(2, queue.poll());
        assertEquals(3, queue.poll());
        assertEquals(4, queue.poll());
        assertEquals(5, queue.poll());
        assertNull(queue.poll());
        db.close();
    }
New to GrepCode? Check out our FAQ X