java里面实现MQ的原理是什么？

Question

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

Answer 1

已经搞好了，写了个死循环，谢谢各位。

Answer 2

假设你是单机模式下while(true){object obj = queue.take();//这里会阻塞的//去做别的处理}

Answer 3

一般数据的放和收对应的是2个线程或进程，以达到异步的目的使得吞吐量最大化。所以你说的是对的，一个不停的add数据，一个不停的get数据，但这样有一个问题，如果你数据添加过慢或过快，或者数据处理的过慢或过快，都会出现队列空或者队列满的情况，这种情况一旦出现，意味着一方要等另一方完成动作才能继续，降低吞吐量，所以一般是会有一个超时返回的。下面一个是无超时的消息队列getpublic 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;        }    }