Thread Object wait() notify()基本
时间:2022-07-24
本文章向大家介绍Thread Object wait() notify()基本,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
package com.thread.test.thread;
import java.util.ArrayDeque;
import java.util.Queue;
import java.util.concurrent.ThreadLocalRandom;
/**
* Created by windwant on 2016/11/29.
*/
public class MyQueueSyn {
public static void main(String[] args) throws InterruptedException {
CR cr = new CR();
cr.addEle(String.valueOf(ThreadLocalRandom.current().nextInt(100)));
cr.start();
new CRP(cr).start();
// for (int i = 0; i < 100; i++) {
// Thread.sleep(1000);
// cr.addEle(String.valueOf(i * i));
// if(i > ThreadLocalRandom.current().nextInt(100)) {
// cr.tify();
// }
// System.out.println("mian thread add cr queue ele: " + i);
// }
}
}
class CRP extends Thread{
private CR cr;
public CRP(CR t){
cr = t;
}
@Override
public void run() {
for (int i = 0; i < 100; i++) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
cr.addEle(String.valueOf(i * i));
if(i > ThreadLocalRandom.current().nextInt(100)) {
cr.tify();
}
System.out.println("mian thread add cr queue ele: " + i);
}
}
}
class CR extends Thread{
public void addEle(String ele) {
synchronized (queue) {
queue.add(ele);
}
}
public void tify(){
synchronized (queue){
queue.notify();
}
}
public Queue<String> queue = new ArrayDeque<>();
@Override
public void run() {
while (true){
synchronized (queue){
try {
if(queue.size() == 0){
System.out.println("cr thread queue wait...");
queue.wait();
}
Thread.sleep(1000);
System.out.println("cr thread queue poll ele: " + queue.poll());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
- python运用中文注释时报错解决方法
- 分页器常用样式
- 分布式监控系统Zabbix-3.0.3--短信报警设置
- linux下用户操作记录审计环境的部署记录
- open-falcon ---客户机agent操作
- 双拼域名yansuan.com被木雨林收购
- open-falcon ---安装Dashboard时候报错"SSLError: The read operation timed out"
- Flash/Flex学习笔记(37):不用系统组件(纯AS3)的视频播放器--只有8.82K
- Flash/Flex学习笔记(35):如何正确监听Stage对象的事件
- Flash/Flex学习笔记(34):AS3中的自定义事件
- 字符串处理总结(旧)
- 计算某年某月的某一天是星期几的算法
- Flash/Flex学习笔记(33):如何用As3协同Flash CS IDE控制MovieClip实例
- live writer的折腾
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 前端知识复习(一)
- Powershell运行脚本报错:此系统上禁止运行脚本
- git rebase解决合并冲突
- npm相关操作
- Angular html property的值如何被更新的
- Centos 7 使用mailx发送邮件
- Centos 7 备份MySQL
- Centos 7 备份MySQL/MongoDB并发邮件脚本
- Nginx启动报错:sbin/nginx: error while loading shared libraries: libpcre.so.1: cannot open shared object
- 有赞美业店铺装修前端解决方案
- nginx部署react项目
- Golang 标准库 限流器 time/rate 设计与实现
- Node搭建简易的UDP服务器
- cordova run android 下载gradle报timeout
- How we redesign the NSQ-NSQ重塑之客户端