package com.yonge.lock;
import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
/**
* 需求:一个线程向一个固定大小的队列里面不停地存放数据,另一个线程不停的向这个队列里面取数据,
* 当队列满了,还继续存放数据,此时出现阻塞,直到队列有空闲的位置;
* 反之,当队列为空,还继续取数据,则也出现阻塞,知道队列中有数据为止
* @author wb-gaoy
* @version $Id: ArrayBlockingQueueTest.java,v 0.1 2012-1-6 上午10:54:11 wb-gaoy Exp $
*/
public class ArrayBlockingQueueTest {
/**
* @param args
*/
public static void main(String[] args) {
//定义阻塞队列
final ArrayBlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(5);
//开启一个put数据的线程
new Thread(new Runnable() {
int i = 0;
@Override
public void run() {
while (true) {
try {
System.out.println("ThreadName:" + Thread.currentThread().getName()
+ ":队列中已存在" + queue.size() + "元素");
if (queue.size() == 5) {
System.out.println("ThreadName:" + Thread.currentThread().getName()
+ ":队列已经满了,阻塞中...");
}
Thread.sleep((long) Math.random() * 10000);
i = new Random().nextInt(100);
System.out.println("ThreadName:" + Thread.currentThread().getName()
+ "准备存放的值为:" + i);
queue.put(i);
System.out.println("ThreadName:" + Thread.currentThread().getName()
+ "已存放的值为:" + i);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}, "A").start();
//开启一个take数据的线程
new Thread(new Runnable() {
@Override
public void run() {
while (true) {
try {
System.out.println("ThreadName:" + Thread.currentThread().getName()
+ ":队列中已存在" + queue.size() + "元素");
if (queue.size() == 0) {
System.out.println("ThreadName:" + Thread.currentThread().getName()
+ ":队列已经空了,阻塞中...");
}
Thread.sleep((long) Math.random() * 10000);
System.out.println("ThreadName:" + Thread.currentThread().getName()
+ "获取的值为:" + queue.take());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}, "B").start();
}
/**
* 总结:上面的代码没有原子性,打印的结果可能会出现偏差
*/
}
分享到:
相关推荐
主要介绍了详细分析Java并发集合ArrayBlockingQueue的用法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
今天小编就为大家分享一篇关于Java源码解析阻塞队列ArrayBlockingQueue常用方法,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
ArrayBlockingQueue提供的增加和取出方法总结 使用ArrayBlockingQueue的一个子类BlockingQueue实现一个可阻塞队列,一个线程put另一个线程take,当队列为空时take等待,当线程满时put等待
ArrayBlockingQueue :由切片支持的有界阻塞队列 LinkedBlockingQueue :由容器/列表支持的有界阻塞队列 ConcurrentRingBuffer :由片支持的有界无锁队列 安装 go get - u github . com / theodesp / blockingQueues...
24.2.1. ArrayBlockingQueue 74 24.2.2. LinkedBlockingQueue 78 24.2.3. LinkedBlockingDeque(双向并发阻塞队列) 84 24.2.4. PriorityBlockingQueue(优先阻塞队列) 85 24.2.5. 总结一下阻塞队列 90 25. Tomcat ...
开源 bbs 源码 java 以下是总结java面试中常见的知识点以及碰到的坑等,经历有限,需待练级! 一、java基础 实例方法和静态方法有什么不一样?...LinkingBlockingQueue与ArrayBlockingQueue的区别,他们
ArrayBlockingQueue LinkedBlockingQueue SynchronousQueue Handler :拒绝处理策略, 线程数量大于最大线程数量就会拒绝处理策略, 四种策略为 ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出...
ArrayBlockingQueue和PriorityBlockingQueue使用较少,一般使用LinkedBlockingQueue和Synchronous。线程池的排队策略与BlockingQueue有关。 threadFactory:线程工厂,主要用来创建线程:默认值 ...
2.2.3. 本地方法区(线程私有) ................................................................................................................ 23 2.2.4. 堆(Heap-线程共享)-运行时数据区 .....................
本地方法区(线程私有) ................................................................................................................ 23 2.2.4. 堆(Heap-线程共享)-运行时数据区 ...........................