java根据wait,notify,synchronize关键字自定义队列
时间:2022-04-29
本文章向大家介绍java根据wait,notify,synchronize关键字自定义队列,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
这里定义了一个有界队列 ,保证先进先出,在队列达到上限时应该阻塞,直到队列有元素被取出才能继续往里继续添加 完整代码:
package com.comic.queue;
import java.util.LinkedList;
import java.util.concurrent.atomic.AtomicInteger;
public class BoundedQueue {
// 队列的最大值
private int maxSize;
// 计数器
private AtomicInteger counter = new AtomicInteger(0);
// 数据容器
private LinkedList<Object> content = new LinkedList<Object>();
// 琐
private Object lock = new Object();
public BoundedQueue(int maxSize) {
this.maxSize = maxSize;
}
/**
* 入队列
*
* @param obj
* @throws InterruptedException
*/
public void put(Object obj) throws InterruptedException {
synchronized (lock) {
while (maxSize == counter.get()) {
System.out.println("队列已满,请等待....");
lock.wait();
}
// 添加元素,计数,唤醒线程
content.add(obj);
counter.getAndIncrement();
lock.notify();
System.out.println(obj + "入列");
}
}
/**
* 取
*
* @return
* @throws InterruptedException
*/
public Object take() throws InterruptedException {
Object obj = null;
synchronized (lock) {
while (0 == counter.get()) {
System.out.println("队列已空,请等待....");
lock.wait();
}
// 获取第一个元素,计数,唤醒线程
obj = content.get(0);
content.remove(0);
counter.decrementAndGet();
lock.notify();
}
return obj;
}
public static void main(String[] args) throws InterruptedException {
final BoundedQueue queue = new BoundedQueue(5);
queue.put("aa");
queue.put("bb");
queue.put("cc");
queue.put("dd");
queue.put("ff");
Thread t = new Thread(new Runnable() {
@Override
public void run() {
try {
queue.put("gg");
queue.put("hh");
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}, "t1");
t.start();
Thread.sleep(500);
System.out.println("**********************************");
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
try {
System.out.println("take:" + queue.take());
System.out.println("take:" + queue.take());
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}, "t2");
t2.start();
}
}
控制台部分: aa入列 bb入列 cc入列 dd入列 ff入列 队列已满,请等待.... ********************************** take:aa gg入列 队列已满,请等待.... take:bb hh入列
- Mac Jenkins搭建 Android/IOS自动打包环境
- javascript 红皮高程(11)
- javascript 红皮高程(8)
- javascript 红皮高程(7)
- javascript 红皮高程(17)-- 左移(<<)
- javascript 红皮高程(17)-- 按位异或(XOR)
- javascript 红皮高程(17)
- javascript 红皮高程(16)
- javascript 红皮高程(15)
- javascript 红皮高程(21)-- 乘性操作符
- javascript 红皮高程(20)-- 逻辑或
- javascript 红皮高程(19)-- 逻辑与
- 技术分享 | 浅谈 RAS
- Sniper-OJ 练习平台多题WriteUp
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- PHP中将一个字符串部分字符用星号*替代隐藏的实现代码
- PHP创建XML的方法示例【基于DOMDocument类及SimpleXMLElement类】
- android之json数据过长打印不全问题的解决
- PHP实现时间日期友好显示实现代码
- AndroidStudio插件GsonFormat之Json快速转换JavaBean教程
- android studio错误: 常量字符串过长的解决方式
- Android Shader着色器/渲染器的用法解析
- PHP实现的文件浏览器功能简单示例
- Laravel中正确地返回HTTP状态码方法示例
- Android 实现抖音头像底部弹框效果的实例代码
- Android Studio修改Log信息颜色的实现
- Android 之BottomsheetDialogFragment仿抖音评论底部弹出对话框效果(实例代码)
- Yii框架的路由配置方法分析
- Android 购物车加减功能的实现代码
- Yii框架函数简单用法分析