LinkedBlockingQueue的学习
2014-11-21 16:37
232 查看
package example;
import java.util.Iterator;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
public class LinkedBlockingQueueTest {
public static void test(){
LinkedBlockingQueue<String> queue=new LinkedBlockingQueue<String>();
queue.offer("1");
queue.offer("2");
queue.offer("3");
queue.offer("4");
Iterator<String> iterator=queue.iterator();
System.out.println("初始队列");
while (iterator.hasNext()) {
System.out.println(iterator.next());
}
queue.poll();//取走队头,非阻塞
System.out.println("取走一个后队头为:"+queue.peek());
queue.poll();//取走队头,非阻塞
queue.poll();//取走队头,非阻塞
queue.poll();//取走队头,非阻塞
String re1=queue.poll();//取走队头,非阻塞,没有就返回null
System.out.println("re1: "+re1);
try {
String result=queue.poll(4, TimeUnit.SECONDS);//等待4秒,如果没取到返回null
System.out.println("等待4秒后result:"+result);
queue.offer("5");
result=queue.take();//取走队头,阻塞方式,如果没取到一直等待
System.out.println("take result: "+result);
} catch (InterruptedException e) {
e.printStackTrace();
}
iterator=queue.iterator();
while (iterator.hasNext()) {
System.out.println(iterator.next());
}
}
/**
* @param args
*/
public static void main(String[] args) {
test();
}
}
import java.util.Iterator;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.TimeUnit;
public class LinkedBlockingQueueTest {
public static void test(){
LinkedBlockingQueue<String> queue=new LinkedBlockingQueue<String>();
queue.offer("1");
queue.offer("2");
queue.offer("3");
queue.offer("4");
Iterator<String> iterator=queue.iterator();
System.out.println("初始队列");
while (iterator.hasNext()) {
System.out.println(iterator.next());
}
queue.poll();//取走队头,非阻塞
System.out.println("取走一个后队头为:"+queue.peek());
queue.poll();//取走队头,非阻塞
queue.poll();//取走队头,非阻塞
queue.poll();//取走队头,非阻塞
String re1=queue.poll();//取走队头,非阻塞,没有就返回null
System.out.println("re1: "+re1);
try {
String result=queue.poll(4, TimeUnit.SECONDS);//等待4秒,如果没取到返回null
System.out.println("等待4秒后result:"+result);
queue.offer("5");
result=queue.take();//取走队头,阻塞方式,如果没取到一直等待
System.out.println("take result: "+result);
} catch (InterruptedException e) {
e.printStackTrace();
}
iterator=queue.iterator();
while (iterator.hasNext()) {
System.out.println(iterator.next());
}
}
/**
* @param args
*/
public static void main(String[] args) {
test();
}
}
相关文章推荐
- LinkedBlockingQueue 源码学习
- Thread学习(九) 并发的Queen学习ArrayBlockingQueue,LinkedBlockingQueue
- Java并发学习笔记(八)-LinkedBlockingQueue
- JDK并发工具类源码学习系列——LinkedBlockingQueue
- Java集合源码学习(17)_BlockingQueue接口的实现LinkedBlockingQueue
- Java核心知识点学习----多线程中的阻塞队列,ArrayBlockingQueue介绍
- java点滴之阻塞队列:PriorityBlockingQueue,SynchronousQueue,LinkedBlockingQueue,ArrayBlockingQueue
- 简析SynchronousQueue,LinkedBlockingQueue,ArrayBlockingQueue
- 并发队列ConcurrentLinkedQueue和阻塞队列LinkedBlockingQueue使用场景总结
- LinkedBlockingQueue
- Java集合源码学习(16)_BlockingQueue接口的实现ArrayBlockingQueue
- LinkedTransferQueue学习导引 推荐
- LinkedBlockingQueue.poll方法测试(转载)
- ArrayBlockingQueue, LinkedBlockingQueue, ConcurrentLinkedQueue, RingBuffer
- Java集合源码学习(15)_Queue接口的实现PriorityQueue和PriorityBlockingQueue
- JDK源码分析—— ArrayBlockingQueue 和 LinkedBlockingQueue
- [JAVA]线程同步队列 LinkedBlockingQueue ConcurrentLinkedQueue
- java.util.concurrent.LinkedBlockingQueue
- 并发队列ConcurrentLinkedQueue和阻塞队列LinkedBlockingQueue用法
- LinkedBlockingQueue vs ConcurrentLinkedQueue