java 线程wait()与notify()的用法

2024-05-25 01:38
文章标签 java 线程 用法 wait notify

本文主要是介绍java 线程wait()与notify()的用法,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!


java 线程wait()与notify()的用法(被唤醒后的线程到底重新执行同步代码块还是从那是等待的那里继续执行)

http://blog.163.com/chen_min163/blog/static/12875356420102921555843/


我们先来看看这两个方法的定义:

      wait()   导致当前线程等待,直到其他线程调用此对象的 notify()方法或 notifyAll()方法前,导致当前线程等待。

     notify()  唤醒在此同步监视器上等待的单个线程,如果有多个线程在此同步监视器上等待,则会唤醒其中的一个,

 

现在假设系统有以一种特殊的要求,系统要求存款者和取款者不断的重复存钱,取钱动作,而且要求每当存款者将存入指定帐号后,取钱者就立即取出该笔钱,不容许存钱者连续两次存钱,也不容许取前者两次取钱,

实现的代码如下:

本程序通过 Account类提供draw与depost两个方法,分别对应该帐户的取钱与存钱操作

<pre name="code" class="java">package junit.thread;public class Account {private String accountNo;// 帐号private double balance;// 余额// 标识账户中是否已有存款的标识private boolean flag = false;public Account() {}public Account(String accountNo, double balance) {this.accountNo = accountNo;this.balance = balance;}public void setAccountNo(String accountNo) {this.accountNo = accountNo;}public String getAccountNo() {return this.accountNo;}public double getBalance() {return this.balance;}public int num = 0;public String name = "haha";public synchronized void draw(double drawAmount) {System.out.println(" 进入 synchronized void draw");try {// 如果flag为假,表明账户中还没有人存钱进去,则取钱方法阻塞if (!flag) {num++;// 将当前线程重命名Thread.currentThread().setName("取钱者AAAAAAAAAAAAAAAAAAA" + " " + num);System.out.println(Thread.currentThread().getName() + " 阻塞");long start = System.currentTimeMillis();wait();name = "取钱失败";System.out.println((System.currentTimeMillis() - start)+ " : ms");} else {// 执行取钱System.out.println(Thread.currentThread().getName() + " 取钱:"+ drawAmount);balance -= drawAmount;System.out.println("账户余额为:" + balance);// 将标识账户是否已有存款的旗标设为false。flag = false;// 唤醒其他线程System.out.println("                    ======取款唤醒其他线程                         ");notifyAll();name = "取钱成功";}System.out.println("==================" + name+ "======================");// System.out.println("这人民共和国==========这人民共和国=====这人民共和国");} catch (InterruptedException ex) {ex.printStackTrace();}}public synchronized void deposit(double depositAmount) {try {// 如果flag为真,表明账户中已有人存钱进去,则存钱方法阻塞if (flag) {wait();} else {// 执行存款System.out.println(Thread.currentThread().getName() + " 存款:"+ depositAmount);balance += depositAmount;System.out.println("账户余额为:" + balance);// 将表示账户是否已有存款的旗标设为trueflag = true;// 唤醒其他线程notifyAll();}} catch (InterruptedException ex) {ex.printStackTrace();}}public int hashCode() {return accountNo.hashCode();}public boolean equals(Object obj) {if (obj != null && obj.getClass() == Account.class) {Account target = (Account) obj;return target.getAccountNo().equals(accountNo);}return false;}
}

 程序中的存钱者线程循环一百次重复存钱,而取前者则循环一百此取钱,存钱者线程,取款这线程分别调用Account对象的deposit,draw方法实现 
package junit.thread;/*** 取款*/
public class DrawThread extends Thread {// 模拟用户账户private Account account; // 当前取钱线程所希望取的钱数private double drawAmount;/*** * @param name  来自于父类 Thread* @param account* @param drawAmount*/public DrawThread(String name, Account account, double drawAmount) {super(name);this.account = account;this.drawAmount = drawAmount;}// 重复100次执行取钱操作public void run() {for (int i = 0; i < 100; i++) {account.draw(drawAmount);}}
}

package junit.thread;/*** 存款*/
public class DepositThread extends Thread {// 模拟用户账户private Account account;// 当前取钱线程所希望存款的钱数private double depositAmount;public DepositThread(String name, Account account, double depositAmount) {super(name);this.account = account;this.depositAmount = depositAmount;}// 重复100次执行存款操作public void run() {for (int i = 0; i < 100; i++) {account.deposit(depositAmount);}}
}





主程序可以启动任意多余条存款和取款线程,可以看到所有取钱线程必须等存款线程存钱后才可以向下执行,而存款线程也必须等待取钱线程取钱后才可以向下执行,主程序代码如下;

package junit.thread;public class TestDraw {public static void main(String[] args) {// 创建一个账户Account acct = new Account("1234567", 0);new DrawThread("取钱者", acct, 800).start();new DepositThread("存款者甲", acct, 800).start();}
}



现在我们步入正题,当一个线程等待被唤醒之后开始执行的地方,这问题曾今也困惑了我好一段时间,

下面我们来将下面的方法里面的代码改一改

public synchronized void draw(double drawAmount){}
 
将它改写成;

注意;我在上面的代码的基础上加了一个全局变量:

public int num = 0;public String name = "haha";public synchronized void draw(double drawAmount) {System.out.println(" 进入 synchronized void draw");try {// 如果flag为假,表明账户中还没有人存钱进去,则取钱方法阻塞if (!flag) {num++;// 将当前线程重命名Thread.currentThread().setName("取钱者AAAAAAAAAAAAAAAAAAA" + " " + num);System.out.println(Thread.currentThread().getName() + " 阻塞");long start = System.currentTimeMillis();wait();name = "取钱失败";System.out.println((System.currentTimeMillis() - start)+ " : ms");} else {// 执行取钱System.out.println(Thread.currentThread().getName() + " 取钱:"+ drawAmount);balance -= drawAmount;System.out.println("账户余额为:" + balance);// 将标识账户是否已有存款的旗标设为false。flag = false;// 唤醒其他线程System.out.println("                    ======取款唤醒其他线程                         ");notifyAll();name = "取钱成功";}System.out.println("==================" + name + "======================");} catch (InterruptedException ex) {ex.printStackTrace();}}


 现在我们来想象一下程序的运行,我们像是启动了一个取款者线程,也就是说当我们帐户上还没有前的时候就去取钱,
 你想象那银行肯定是不干的咯,所以它会进入等待,进入等待之后我们将它给重命名
 (末尾加上了一个数字,这数字代表进入等待的次数),它进入等待之后在等待者存款线程改变它的状态,
 并且等待者要它用notfy()来将它唤醒,现在我们假设它有两种执行状况

(1):被唤醒之后从新从该同步代码块执行,此时控制台会输出“进入 synchronized    void draw”此时它应该进入

     else()块内,也就是说它现在应该就可以取钱了,然后看到控制台输出"==================取钱成功======================",

(2):继续从等待的地方(wait()方法之后)执行,又由于if与else是相对立的,所以它不会进入else里面,所以线程这

     次 进入线程是空着手出去的(取钱没有成功),所以你会看到控制台输出"==================取钱失败======================",

然后在输出“进入 synchronized  void draw”然后在进行取钱操作,

 

而事实确实如第二种情况;

所以总结有:

 

在Java对象中,有两种池
琐池-----------------------synchronized
等待池---------------------wait(),notify(),notifyAll()
如果一个线程调用了某个对象的wait方法,那么该线程进入到该对象的等待池中(并且已经将锁释放),
如果未来的某一时刻,另外一个线程调用了相同对象的notify方法或者notifyAll方法,
那么该等待池中的线程就会被唤起,然后进入到对象的锁池里面去获得该对象的锁,
如果获得锁成功后,那么该线程就会沿着wait方法之后的路径继续执行。注意是沿着wait方法之后

这篇关于java 线程wait()与notify()的用法的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1000122

相关文章

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时,有没有考虑过 JVM 是如何把静态的字节码(byte code)转化为运行时对象的呢,这个问题看似简单,但清楚的同学相信也不会太多,这篇文章首先介绍 JVM 类初始化的机制,然后给出几个易出错的实例来分析,帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段,分别是:loading 、Linking、initialization

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权,允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true (Spring security默认会带有ROLE_前缀),去

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程,特意画了如下的类图,包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口,接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类,它们之间的依赖,构建起了整个框架。想要理解整个架构,最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文(security context)的信息。当前操作的用户是谁,该用户是否已经被认证,他拥有哪些角色权限…这些都被保

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明(认真看哦) AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证,则会调用 #attemptAuthentica

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物

Java进阶13讲__第12讲_1/2

多线程、线程池 1.  线程概念 1.1  什么是线程 1.2  线程的好处 2.   创建线程的三种方式 注意事项 2.1  继承Thread类 2.1.1 认识  2.1.2  编码实现  package cn.hdc.oop10.Thread;import org.slf4j.Logger;import org.slf4j.LoggerFactory

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来,一站式有声阅读平台听书系统 🌟&nbsp;开篇:遇见未来,从“智听”开始 在这个快节奏的时代,你是否渴望在忙碌的间隙,找到一片属于自己的宁静角落?是否梦想着能随时随地,沉浸在知识的海洋,或是故事的奇幻世界里?今天,就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统,它正悄悄改变着我们的阅读方式,让未来触手可及! 📚&nbsp;第一站:海量资源,应有尽有 走进“智听

在cscode中通过maven创建java项目

在cscode中创建java项目 可以通过博客完成maven的导入 建立maven项目 使用快捷键 Ctrl + Shift + P 建立一个 Maven 项目 1 Ctrl + Shift + P 打开输入框2 输入 "> java create"3 选择 maven4 选择 No Archetype5 输入 域名6 输入项目名称7 建立一个文件目录存放项目,文件名一般为项目名8 确定