ArrayBlockingQueue
同步队列超出长度时,不同的返回形式可以分为以下四种。
会抛异常 | 不会抛异常,有返回值 | 死等,直到可以插入值或者取到值 | 设置等待超时时间 | |
添加方法 | add() | offfer() | put() | offer(E e,long timeout, TimeUnit unit) |
删除方法 | remove() | poll() | take() | poll(long timeout, TimeUnit unit) |
add() & remove():
- add()方法没有返回值
- remove()删除队列元素并返回。
//创建一个长度为3的队列
ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(3);
queue.add("a");
queue.add("b");
queue.add("c");//存放的元素个数超过队列长度时抛出异常
//java.lang.IllegalStateException: Queue full
//queue.add("d");System.out.println(queue.remove());
System.out.println(queue.remove());
System.out.println(queue.remove());//取出队列元素,为空时抛出异常,java.util.NoSuchElementException
//System.out.println(queue.remove());
offer() & pull()
- offer()存储成功时返回true,失败返回false
- pull()取出元素,队列为空时返回null
//创建一个长度为3的队列
ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(3);
System.out.println(queue.offer("a"));
System.out.println(queue.offer("b"));
System.out.println(queue.offer("c"));//存放的元素个数超过队列长度时,返回false
System.out.println(queue.offer("d"));System.out.println(queue.poll());
System.out.println(queue.poll());
System.out.println(queue.poll());//队列为空时返回null
System.out.println(queue.poll());
put() & take()
- put()存放元素队列满时,将无限期等待,直到有空位
- take()取出元素队列为空时,将无限期等待,直到取到
//创建一个长度为3的队列
ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(3);
queue.put("a");
queue.put("b");
queue.put("c");
//没有位置时将阻塞,无限期等待
//queue.put("d");System.out.println(queue.take());
System.out.println(queue.take());
System.out.println(queue.take());
//队列为空时将阻塞,无限期等待
//System.out.println(queue.take());
offer(E e,long timeout, TimeUnit unit) & pull(long timeout, TimeUnit unit)
- offer()中e为要存放的元素,timeout为等待超时时间,unit为等待超时时间单位(天、时、分、秒、毫秒)
- pull()中timeout、unit与offer()意思一样
//创建一个长度为3的队列
ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(3);
System.out.println(queue.offer("a"));
System.out.println(queue.offer("b"));
System.out.println(queue.offer("c"));//存放的元素个数超过队列长度时,等待3秒,还不能存,返回false
System.out.println(queue.offer("d", 3, TimeUnit.SECONDS));System.out.println(queue.poll());
System.out.println(queue.poll());
System.out.println(queue.poll());队列为空时,等待3秒,还为空则返回null
System.out.println(queue.poll(3,TimeUnit.SECONDS));