`

synchronized (this) 柳暗花明又一村

 
阅读更多

 今天写一个测试类,主要是测试wait(long timeout)到底会不会自动notify,到后来发现

一些很诡异的东西。

package com.hp.thread.chapter04;

public class WaitAndNotify {
	private Object obj = new Object();
	public static void testPureWait(){
		new Thread(new Runnable(){
			public void run() {
				synchronized (this) {
					try {
						System.out.println("thread 0");
						wait();
						System.out.println("thread 0 waited...");
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			}
		}).start();
		new Thread(new Runnable(){
			public void run() {
				synchronized (this) {
					try {
						System.out.println("thread 1");
						wait(1000);
						System.out.println("thread 1 waited...");
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			}
		}).start();
	}
	
	public void testWait1000(){
		new Thread(new Runnable(){
			public void run() {
				System.out.println("thread 0 " + this);
				synchronized (obj) {
					while(true){
						try {
							System.out.println("thread 0 running...");
							Thread.sleep(1000);
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
					}
				}
			}
		}).start();
		new Thread(new Runnable(){
			public void run() {
				System.out.println("thread 1 " + this);
				synchronized (obj) {
					try {
						while(true){
							wait(1000);
							System.out.println("thread 1 waited...");
						}
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			}
		}).start();
	}
	//通过打印出来的this,发现2个是不同的结果,为什么呢?
	//因为this是指向当前对象的引用,不过方法中都是new Thread(new Runnable(){}).start()
	//方式来生成,都是通过匿名的方式,所以每次的this都是指向new Thread()的WaitAndNotify对象
	public void testWait1000_2(){
		new Thread(new Runnable(){
			public void run() {
				synchronized (this) {
					while(true){
						try {
							System.out.println("thread 0");
							System.out.println("thread 0 running...");
							Thread.sleep(1000);
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
					}
				}
			}
		}).start();
		new Thread(new Runnable(){
			public void run() {
				synchronized (this) {
					try {
						while(true){
							System.out.println("thread 1");
							wait(1000);
							System.out.println("thread 1 waited...");
						}
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}
			}
		}).start();
	}
	
	public static void testWait(){
		new Thread(new Runnable(){
			public void run() {
				while(true){
					synchronized (this) {
						try {
							System.out.println("...");
							wait();
							System.out.println("waited...");
							notifyAll();
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
					}
				}
			}
		}).start();
		
		new Thread(new Runnable(){
			public void run() {
				while(true){
					synchronized (this) {
						try {
							notifyAll();
							System.out.println("notify...");
							wait();
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
					}
				}
			}
		}).start();
	}
	
	/**
	 * @param args
	 */
	public static void main(String[] args) {
//		testPureWait();
//		testWait();
		new WaitAndNotify().testWait1000();
	}

}

 调用testWait1000_2方法得到的结果不是我期望(线程0始终在运行,线程1是不会运行的),但世界的结果恰恰相反,好事2个线程不相干,测试结果如下

thread 0
thread 0 running...
thread 1
thread 1 waited...
thread 0
thread 0 running...
thread 1
thread 0
thread 0 running...
thread 1 waited...
thread 1

 但是运行testWait1000正好是我要的结果,开始百思不得其解,后来打印this发现mystery了

thread 0 com.hp.thread.chapter04.WaitAndNotify$3@525483cd
thread 0 running...
thread 1 com.hp.thread.chapter04.WaitAndNotify$4@67f1fba0
thread 0 running...
thread 0 running...
thread 0 running...
thread 0 running...

 发现2个this的地址完全不一样,细想一下豁然开朗。

分享到:
评论
7 楼 tojaoomy 2013-05-20  
teasp 写道
tojaoomy 写道
teasp 写道
tojaoomy 写道
teasp 写道
匿名类的this当然是指向匿名类对象自身了。我好奇的是你为什么要“测试wait(long timeout)到底会不会自动notify”。测试的结果是什么呢?

结果是会notify

如果我告诉你你的结果是错误的呢?

错误的?不解,那就麻烦你说一下原因?
这是我的理解,timeout时间一过,该线程立马notify,不过会等待
对象锁,不是waiting状态了,而是等待锁的状态。

这是当然的啊,还用测试吗?我以为你测的是时间还没到,wait的线程就自己醒了呢。

呵呵,理论终归是理论,还是要实践的。
而我测试的目的是notify后的reaction是什么罢了。
6 楼 teasp 2013-05-20  
tojaoomy 写道
teasp 写道
tojaoomy 写道
teasp 写道
匿名类的this当然是指向匿名类对象自身了。我好奇的是你为什么要“测试wait(long timeout)到底会不会自动notify”。测试的结果是什么呢?

结果是会notify

如果我告诉你你的结果是错误的呢?

错误的?不解,那就麻烦你说一下原因?
这是我的理解,timeout时间一过,该线程立马notify,不过会等待
对象锁,不是waiting状态了,而是等待锁的状态。

这是当然的啊,还用测试吗?我以为你测的是时间还没到,wait的线程就自己醒了呢。
5 楼 tojaoomy 2013-05-20  
teasp 写道
tojaoomy 写道
teasp 写道
匿名类的this当然是指向匿名类对象自身了。我好奇的是你为什么要“测试wait(long timeout)到底会不会自动notify”。测试的结果是什么呢?

结果是会notify

如果我告诉你你的结果是错误的呢?

错误的?不解,那就麻烦你说一下原因?
这是我的理解,timeout时间一过,该线程立马notify,不过会等待
对象锁,不是waiting状态了,而是等待锁的状态。
4 楼 teasp 2013-05-20  
tojaoomy 写道
teasp 写道
匿名类的this当然是指向匿名类对象自身了。我好奇的是你为什么要“测试wait(long timeout)到底会不会自动notify”。测试的结果是什么呢?

结果是会notify

如果我告诉你你的结果是错误的呢?
3 楼 tojaoomy 2013-05-19  
package com.hp.thread;

import java.util.Random;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class CyclicBarrierTest {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		CyclicBarrier barrier = new CyclicBarrier(3,new Runnable() {
			
			@Override
			public void run() {
				System.out.println("get together");
			}
		});
		ExecutorService executor = Executors.newFixedThreadPool(3);
		executor.submit(new Thread(new Runner(barrier, "1号选手")));
        executor.submit(new Thread(new Runner(barrier, "2号选手")));
        executor.submit(new Thread(new Runner(barrier, "3号选手")));
        executor.shutdown();

	}

}

class Runner implements Runnable{
	private CyclicBarrier barrier;
	private String name;
	
	public Runner(CyclicBarrier barrier,String name) {
		this.barrier = barrier;
		this.name = name;
	}
	@Override
	public void run() {
		try {
			Thread.sleep(1000*(new Random().nextInt(2)));
			System.out.println( name + " ready...");
			barrier.await();
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (BrokenBarrierException e) {
			e.printStackTrace();
		}
		System.out.println(name + "go!");
	}
	
}
2 楼 tojaoomy 2013-05-19  
teasp 写道
匿名类的this当然是指向匿名类对象自身了。我好奇的是你为什么要“测试wait(long timeout)到底会不会自动notify”。测试的结果是什么呢?

结果是会notify
1 楼 teasp 2013-05-17  
匿名类的this当然是指向匿名类对象自身了。我好奇的是你为什么要“测试wait(long timeout)到底会不会自动notify”。测试的结果是什么呢?

相关推荐

    基于springboot共享经济背景下校园闲置物品交易平台源码数据库文档.zip

    基于springboot共享经济背景下校园闲置物品交易平台源码数据库文档.zip

    基于WoodandBerry1和非耦合控制WoodandBerry2来实现控制木材和浆果蒸馏柱控制Simulink仿真.rar

    1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。

    emcopy042002.zip

    emcopy042002.zip

    (源码)基于Python的遥感图像语义分割系统.zip

    # 基于Python的遥感图像语义分割系统 ## 项目简介 本项目是一个基于Python的遥感图像语义分割系统,专注于处理和分析遥感图像数据。系统采用HRNet(High Resolution Network)架构,结合多尺度训练和翻转增强等技术,实现对图像的像素级分类,从而完成语义分割任务。 ## 项目的主要特性和功能 1. HRNet架构利用HRNet架构并行处理不同分辨率的特征,有效捕获图像细节和上下文信息,提升分割精度。 2. 多尺度训练支持多尺度训练,通过不同尺度的缩放和裁剪,增加数据多样性,提高模型泛化能力。 3. 翻转增强在训练过程中对图像进行随机翻转,增加数据集多样性,提高模型鲁棒性。 4. 预处理和增强提供多种预处理和增强技术,如随机色调、饱和度、亮度调整,以及平移、缩放、旋转等变换,用于扩充数据集和增强模型性能。

    (源码)基于Spring Boot的博客管理系统.zip

    # 基于Spring Boot的博客管理系统 ## 项目简介 本项目是一个基于Spring Boot框架的博客管理系统,旨在提供一个简单易用的博客平台,支持用户登录认证、文章管理、分类管理、标签管理等功能。项目主要用于学习和实践Spring Boot及相关技术,特别是登录认证和权限管理方面的内容。 ## 项目的主要特性和功能 1. 用户管理 用户注册、登录、信息更新。 用户权限管理,支持超级管理员和普通用户角色。 2. 文章管理 文章的创建、编辑、删除、恢复。 文章的分类和标签管理。 文章的发布状态管理(草稿、已发布、回收站)。 3. 分类管理 分类的添加、删除、更新。 分类信息的查询。 4. 标签管理 标签的添加、删除、更新。 标签与文章的关联管理。 5. 数据统计 文章的浏览量统计。 分类和标签的数据统计。

    基于springboot的中医院问诊系统源码数据库文档.zip

    基于springboot的中医院问诊系统源码数据库文档.zip

    基于SpringBoot+Vue的校园篮球联赛管理系统源码数据库文档.zip

    基于SpringBoot+Vue的校园篮球联赛管理系统源码数据库文档.zip

    基于springboot框架药品购买系统源码数据库文档.zip

    基于springboot框架药品购买系统源码数据库文档.zip

    人工智能开发项目深度学习项目源码带指导视频一起来动动手

    人工智能开发项目深度学习项目源码带指导视频一起来动动手提取方式是百度网盘分享地址

    (源码)基于Spring Boot和Vue的基金管理系统.zip

    # 基于Spring Boot和Vue的基金管理系统 ## 项目简介 本项目是一个基于Spring Boot和Vue框架的基金管理系统,旨在提供一个全面的基金管理解决方案。系统涵盖了基金的各个方面,包括账户管理、交易记录、报表生成、用户权限管理等功能。通过前后端分离的架构,系统能够高效地处理大量数据,并提供友好的用户界面。 ## 项目的主要特性和功能 ### 1. 用户管理 用户注册与登录支持用户注册和登录功能,确保用户身份的安全性。 用户权限管理根据用户角色分配不同的权限,确保系统的安全性。 ### 2. 账户管理 基金账户创建与管理支持创建和管理多个基金账户,记录账户的余额、交易记录等信息。 账户冻结与解冻支持账户的冻结和解冻操作,确保账户的安全性。 ### 3. 交易管理 交易记录管理记录所有的交易操作,包括买入、卖出、转账等。 交易报表生成自动生成交易报表,方便用户查看和分析交易情况。 ### 4. 报表与统计

    springboot316社团服务系统的设计与实现.zip

    论文描述:该论文研究了某一特定领域的问题,并提出了新的解决方案。论文首先对问题进行了详细的分析和理解,并对已有的研究成果进行了综述。然后,论文提出了一种全新的解决方案,包括算法、模型或方法。在整个研究过程中,论文使用了合适的实验设计和数据集,并进行了充分的实验验证。最后,论文对解决方案的性能进行了全面的评估和分析,并提出了进一步的研究方向。 源码内容描述:该源码实现了论文中提出的新的解决方案。源码中包含了算法、模型或方法的具体实现代码,以及相关的数据预处理、实验设计和性能评估代码。源码中还包括了合适的注释和文档,以方便其他研究者理解和使用。源码的实现应该具有可读性、可维护性和高效性,并能够复现论文中的实验结果。此外,源码还应该尽可能具有通用性,以便在其他类似问题上进行进一步的应用和扩展。

    (源码)基于Arduino的蒸发冷却系统.zip

    # 基于Arduino的蒸发冷却系统 ## 项目简介 本项目旨在创建一个蒸发冷却系统(即沼泽冷却器),这是一种在干燥炎热气候下提供能源效率替代空调的系统。该系统使用Arduino 2560和各种传感器来监控和控制冷却过程。 ## 项目的主要特性和功能 水位监控通过水位传感器监控水箱中的水位,并在水位过低时发出警报。 温度和湿度显示在LCD屏幕上显示空气温度和湿度。 风扇控制根据温度范围控制风扇电机。 系统开关通过用户按钮控制系统的开关。 日志记录记录电机激活和停用的时间和日期。 ## 安装使用步骤 2. 硬件连接按照项目文档中的电路图连接所有硬件组件,包括水位传感器、LCD显示屏、实时时钟模块、DHT11传感器和风扇电机。 3. 上传代码将下载的代码上传到Arduino 2560开发板。 4. 启动系统通过用户按钮启动系统,观察LCD屏幕上的温度和湿度显示,并监控水位传感器的状态。

    基于springboot的社区快递上门服务系统源码数据库文档.zip

    基于springboot的社区快递上门服务系统源码数据库文档.zip

    【多智能体任务分配】基于共识的捆绑算法CBBA实现远程太空船RPO 规划任务研究附Matlab代码.rar

    1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。

    基于RNN生成文本(自然语言处理)

    此代码基于PTB数据集,实现了一个具有一定泛化能力的语言模型。可指定初始单词和生成单词数生成文本

    【故障诊断】基于改进的稀疏周期组Lasso的轴承故障诊断Matlab代码.rar

    1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。

    IEEE 14节点标准模型的柴油发电机、光伏模型、电池储能系统、电弧炉等非线性负载复合微电网模型Simulink仿真.rar

    1.版本:matlab2014/2019a/2024a 2.附赠案例数据可直接运行matlab程序。 3.代码特点:参数化编程、参数可方便更改、代码编程思路清晰、注释明细。 4.适用对象:计算机,电子信息工程、数学等专业的大学生课程设计、期末大作业和毕业设计。

    JavaScript:模块化编程与CommonJS技术详解

    内容概要:本文详细介绍了JavaScript的模块化编程及其在CommonJS中的实现方法。首先解释了模块化编程的重要性和在JavaScript中的应用,接着具体讲述了CommonJS的规范和实现细节,包括模块的定义、导出、导入及缓存机制。文中还包括了大量的代码示例,帮助读者更好地理解和实践模块化编程的技术要点。此外,还讨论了异步和动态加载模块的方法以及处理循环依赖的最佳实践。 适合人群:具备一定JavaScript基础的开发人员,尤其是对模块化编程和Node.js感兴趣的开发者。 使用场景及目标:帮助开发者掌握JavaScript模块化编程的核心概念和技术,提升代码的可读性、可维护性和可复用性,特别是在大规模项目中。 阅读建议:建议读者跟随文章中的示例逐步实践,深入理解CommonJS规范及其在实际项目中的应用,同时关注ES模块与CommonJS的区别和各自的优缺点。

    基于 Van.js 的简单前端路由组件(支持字符串和正则表达式匹配等).zip

    一个基于 Van.js 的简单前端路由组件。它支持字符串和正则表达式匹配,可以设置页面显示延迟,并且可以配置首次路由匹配(onFirst)和后续路由匹配(onLoad)的事件。该项目使用 TypeScript 实现,提供了简单的 API。 主要功能点 支持字符串和正则表达式匹配 支持设置页面显示延迟 支持配置首次路由匹配(onFirst)和后续路由匹配(onLoad)的事件 使用 TypeScript 实现 提供简单的 API 技术栈 Van.js TypeScript

    (源码)基于Spring Boot和Vue的ELADMIN后台管理系统.zip

    # 基于Spring Boot和Vue的ELADMIN后台管理系统 ## 项目简介 ELADMIN是一个基于Spring Boot 2.1.0、Spring Boot Jpa、JWT、Spring Security、Redis、Vue的前后端分离的后台管理系统。该项目提供了丰富的功能和特性,适用于各种企业级应用的开发。 ## 项目的主要特性和功能 技术栈使用最新技术栈,社区资源丰富。 高效率开发代码生成器可一键生成前后端代码。 数据字典支持数据字典,方便对一些状态进行管理。 接口限流支持接口限流,避免恶意请求导致服务层压力过大。 权限管理支持接口级别的功能权限与数据权限,可自定义操作。 自定义权限注解自定义权限注解与匿名接口注解,可快速对接口拦截与放行。 前端组件封装对一些常用的前端组件进行封装,如表格数据请求、数据字典等。 统一异常处理前后端统一异常拦截处理,统一输出异常,避免繁琐的判断。

Global site tag (gtag.js) - Google Analytics