Home
Search
Register
Log inBlocking Queue
Page 1 of 1
Blocking Queue
Admin Mon Nov 21, 2011 3:15 pm
public class BlockingQueue{
private List queue=new LinkedList();
private int limit=10;
public BlockingQueue(int limit){
this.limit=limit;
}
public synchronized void enqueue(Object item){
while(this.queue.size()==this.limit){
wait();
}
if(this.queue.size()==0){
notifyAll();
}
this.queue.add(item);
}
}
private List queue=new LinkedList();
private int limit=10;
public BlockingQueue(int limit){
this.limit=limit;
}
public synchronized void enqueue(Object item){
while(this.queue.size()==this.limit){
wait();
}
if(this.queue.size()==0){
notifyAll();
}
this.queue.add(item);
}
}
Admin- Admin
- Posts : 131
Join date : 2011-08-16 -
Page 1 of 1
Permissions in this forum:
You cannot reply to topics in this forum|
|
|