java - 使用 FIFO 缓冲区的正确方法

Question

我有这个 FIFO，我将用它来存储来自网络服务器的数据:

 Buffer nServerFifo = (Buffer) BufferUtils.synchronizedBuffer(new CircularFifoBuffer(200));

    // Insert into to the Network Server Buffer    
    public void nServerFifoAdd(String string){
        nServerFifo.add(string);        
    }

    // Get data from the Network Server Buffer
    public Object nServerFifoGet(){         
        Object string = nServerFifo.get();    
        nServerFifo.remove(string);
        return string;           
    }

我的问题是存储数据插入和从缓冲区获取数据的正确方法是什么？我是否需要在我得到 if 或者这是由缓冲区完成后删除数据？您知道我可以存储到缓冲区中的最大字符串长度是多少吗？

Answer 1

最好使用java.util.concurrent 包中的ArrayBlockingQueue 类，它是线程安全的。

BlockingQueue<String> queue = new ArrayBlockingQueue<String>(100);

queue.put("Vivek");   // To insert value into Queue

queue.take();         // To take the value out of Queue