我现在想做一个消息队列,一边在不停的放数据,一边在不停的take,怎么保证这个take一直在执行?,是不是要写一个死循环的?还是有别的什么方式?
光阴似箭催人老,日月如移越少年。
已经搞好了,写了个死循环,谢谢各位。
假设你是单机模式下
while(true){
object obj = queue.take();//这里会阻塞的 //去做别的处理
}
一般数据的放和收对应的是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; } }
已经搞好了,写了个死循环,谢谢各位。
假设你是单机模式下
while(true){
}
一般数据的放和收对应的是2个线程或进程,以达到异步的目的使得吞吐量最大化。所以你说的是对的,一个不停的add数据,一个不停的get数据,但这样有一个问题,如果你数据添加过慢或过快,或者数据处理的过慢或过快,都会出现队列空或者队列满的情况,这种情况一旦出现,意味着一方要等另一方完成动作才能继续,降低吞吐量,所以一般是会有一个超时返回的。
下面一个是无超时的消息队列get