java并发队列
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了java并发队列，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4586字，纯文字阅读大概需要7分钟。
内容图文
阻塞队列
常见的阻塞队列有ArrayBlockingQueue，LinkedBlockingDeque，LinkedBlockingQueue，这些队列有界且可以阻塞线程
ArrayBlockingQueue
ArrayBlockingQueue是有界的阻塞队列，LinkedBlockingDeque通过数组、非空和非满Condition、RantrantLock实现了线程安全。空的时候take阻塞，满的时候put阻塞
java并发初探LinkedBlockingQueue
LinkedBlockingQueue是有界的阻塞队列，通过head,last节点，putLock插入锁，takeLock取锁、非空和非满condition、单向链表实现了线程安全的阻塞队列，空的时候take阻塞，满的时候put阻塞
java并发初探LinkedBlockingQueue
LinkedBlockingQueue是有界的阻塞队列，通过head,last节点，putLock插入锁，takeLock取锁、非空和非满condition、单向链表实现了线程安全的阻塞队列，空的时候take阻塞，满的时候put阻塞
非阻塞队列
java并发初探ConcurrentLinkedQueue
ConcurrentLinkedQueue是线程安全的无界队列，通过volatile和CAS操作保证了线程安全。
例子
阻塞队列当满的时候put元素回阻塞，实现队列接口的LinkedList在多线程的时候会跑出ConcurrentModifExeception异常
package com.java.javabase.thread.collection;
import lombok.extern.slf4j.Slf4j;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.Map;
import java.util.Queue;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.LinkedBlockingQueue;
/**
* @author
*/
@Slf4j
public class BlockingQueueTest {
/* public static Queue<String> queue = new ArrayBlockingQueue<String>(20);
public static ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(20);
public static LinkedBlockingDeque<String> queue = new LinkedBlockingDeque<String>(20);
public static LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<String>(20);
public static Queue<String> queue =new LinkedList<String>();
public static ConcurrentLinkedQueue<String> queue = new ConcurrentLinkedQueue<String>();
*/
public static ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(20);
public static int size = 15;
public static void main(String[] args) {
Thread t1 = new InnerThread("t1");
Thread t2 = new InnerThread("t2");
t1.start();
t2.start();
try {
Thread.sleep(2000);
printQueue(queue);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
static class InnerThread extends Thread {
String name;
public InnerThread(String name) {
super(name);
this.name=name;
}
@Override
public void run() {
for (int i = 0; i < size; i++) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
String tmp=i+" "+name;
//queue.add(tmp);
try {
queue.put(tmp);
//queue.add(tmp);
} catch (InterruptedException e) {
log.error("error",e);
}
printQueueNone(queue);
}
}
}
public static void printQueue(Queue queue) {
Iterator iterator = queue.iterator();
while (iterator.hasNext()) {
log.info("thread {} print {}", Thread.currentThread().getName(), iterator.next());
}
}
public static void printQueueNone(Queue queue) {
Iterator iterator = queue.iterator();
while (iterator.hasNext()) {
iterator.next();
}
}
}
运行结果
2019-08-28 19:42:32,684 [main] INFO BlockingQueueTest - thread main print 0 t1
2019-08-28 19:42:32,686 [main] INFO BlockingQueueTest - thread main print 0 t2
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 1 t2
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 1 t1
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 2 t2
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 2 t1
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 3 t1
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 3 t2
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 4 t2
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 4 t1
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 5 t2
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 5 t1
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 6 t1
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 6 t2
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 7 t1
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 7 t2
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 8 t2
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 8 t1
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 9 t2
2019-08-28 19:42:32,687 [main] INFO BlockingQueueTest - thread main print 9 t1内容总结
以上是互联网集市为您收集整理的java并发队列全部内容，希望文章能够帮你解决java并发队列所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。