消息队列 - java里面实现MQ的原理是什么？

Question

我现在想做一个消息队列，一边在不停的放数据，一边在不停的take，怎么保证这个take一直在执行？，是不是要写一个死循环的？还是有别的什么方式？

Answer 1

已經搞好了，寫了個死循環，謝謝各位。

Answer 2

假設你是單機模式下

while(true){

object obj = queue.take();//这里会阻塞的
//去做别的处理

}

Answer 3

一般資料的放和收對應的​​是2個執行緒或進程，以達到非同步的目的使得吞吐量最大化。所以你說的是對的，一個不停的add數據，一個不停的get數據，但這樣有一個問題，如果你數據添加過慢或過快，或者數據處理的過慢或過快，都會出現隊列空或佇列滿的情況，這種情況一旦出現，意味著一方要等另一方完成動作才能繼續，降低吞吐量，所以一般是會有一個超時回傳的。
下面一個是無逾時的訊息佇列get

public Message receive() throws InterruptedException {
        
        synchronized (queue) {
            
            if(queue.isEmpty()){
                queue.wait(1000);
            }
            if(queue.isEmpty()){
                return null;//timeout
            }
            Message message=queue.get(0);
            queue.remove(0);
            return message;
        }

    }