Java可阻塞队列-ArrayBlockingQueue
作者:网络转载 发布时间:[ 2016/1/18 10:12:49 ] 推荐标签:测试开发技术 Java
在前面的的文章,写了一个带有缓冲区的队列,是用JAVA的Lock下的Condition实现的,但是JAVA类中提供了这项功能,是ArrayBlockingQueue,
ArrayBlockingQueue是由数组支持的有界阻塞队列,次队列按照FIFO(先进先出)原则,当队列已经填满,在去增加则会导致阻塞,这种阻塞类似线程阻塞。
ArrayBlockingQueue提供的增加和取出方法总结
使用ArrayBlockingQueue的一个子类BlockingQueue实现一个可阻塞队列,一个线程put另一个线程take,当队列为空时take等待,当线程满时put等待
此实现方式没有线程互斥
import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
/**
* 可阻塞的队列
* BlockingQueue
* 此方式不能实现线程互斥
* @author
*
*/
public class BlockingQueueCommunicationTest {
public static void main(String[] args) {
final BlockingQueue<Integer> queue = new ArrayBlockingQueue<Integer>(3);
new Thread(new Runnable() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(new Random().nextInt(1000));
System.out.println("线程"
+ Thread.currentThread().getName() + "准备增加");
queue.put(1);
System.out.println("线程"
+ Thread.currentThread().getName() + "已增加,队列有"
+ queue.size() + "个");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}).start();
new Thread(new Runnable() {
@Override
public void run() {
while (true) {
try {
Thread.sleep(new Random().nextInt(1000));
System.out.println("线程"
+ Thread.currentThread().getName() + "准备取走");
queue.take();
System.out.println("线程"
+ Thread.currentThread().getName() + "已取走,队列剩余"
+ queue.size() + "个");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}).start();
}
}
相关推荐
更新发布
功能测试和接口测试的区别
2023/3/23 14:23:39如何写好测试用例文档
2023/3/22 16:17:39常用的选择回归测试的方式有哪些?
2022/6/14 16:14:27测试流程中需要重点把关几个过程?
2021/10/18 15:37:44性能测试的七种方法
2021/9/17 15:19:29全链路压测优化思路
2021/9/14 15:42:25性能测试流程浅谈
2021/5/28 17:25:47常见的APP性能测试指标
2021/5/8 17:01:11