黑马程序员技术交流社区

标题: 多线程通信--传统线程通信 [打印本页]
作者: a80C51    时间: 2015-9-29 23:37
标题: 多线程通信--传统线程通信
1）使用wait()、notify()和notifyAll()三个方法，来控制线程之间的调度。
2）上述三个方法属于Object类，必须由同步监视器来调用。
3）三种方法的解释：
        a，wait()，导致当前线程等待，直到其他线程调用该同步监视器的notify()方法或者notifyAll()方法来唤醒该线程。
        b，notify(),唤醒在此同步监视器上等待的单个线程，如果所有的线程都在此同步监视器上等待，则会选择唤醒其中一个，只有当前线程放弃锁定后，才可以执行被唤醒的线程；
        c，notifyAll(),唤醒在此同步监视器上等待的所有线程。只有当前线程放弃对该同步监视器的锁定后，才可以执行被唤醒的线程。
4）源码示例
//Account.java代码
  1. package com.wayne.practice;

  3. public class Account {
  4.         private String accountNo;
  5.         private double balance;
  6.        
  7.         //设置是否账户中是否有钱的标志
  8.         private boolean bFlagHasMoney = false;
  9.        
  10.         public Account(){}

  12.         public Account(String accountNo, double balance) {
  13.                 super();
  14.                 this.accountNo = accountNo;
  15.                 this.balance = balance;
  16.         }

  18.         public String getAccountNo() {
  19.                 return accountNo;
  20.         }

  22.         public void setAccountNo(String accountNo) {
  23.                 this.accountNo = accountNo;
  24.         }

  26.         public double getBalance() {
  27.                 return balance;
  28.         }

  30.         @Override
  31.         public int hashCode() {
  32.                 return accountNo.hashCode();
  33.         }

  35.         @Override
  36.         public boolean equals(Object obj) {
  37.                 if(this == obj)
  38.                         return true;
  39.                
  40.                 if((obj != null)&&(obj.getClass() == Account.class))
  41.                 {
  42.                         Account account = (Account)obj;
  43.                         if(this.getAccountNo().equals(account.getAccountNo()))
  44.                                         return true;
  45.                 }
  46.                
  47.                 return false;
  48.         }
  49.        
  50.         //定义取钱的动作
  51.         public synchronized void draw(double drawMoney)
  52.         {
  53.                 if(!bFlagHasMoney)
  54.                 {
  55.                         try {
  56.                                 wait();//如果bFlagHasMoney为假，则表示账户中没有钱，阻塞该取钱
  57.                         } catch (InterruptedException e) {
  58.                                 // TODO Auto-generated catch block
  59.                                 e.printStackTrace();
  60.                         }
  61.                 }
  62.                 else
  63.                 {
  64.                         System.out.println(Thread.currentThread().getName()+
  65.                                         " 取款："+drawMoney+"元！");
  66.                         this.balance-=drawMoney;
  67.                         System.out.println("账户余额为："+this.getBalance());
  68.                         bFlagHasMoney = false;
  69.                         notifyAll();
  70.                 }
  71.         }
  72.        
  73.         //定义存钱动作
  74.         public synchronized void deposit(double depositMoney)
  75.         {
  76.                 if(bFlagHasMoney)
  77.                 {
  78.                         try {
  79.                                 wait();////如果bFlagHasMoney为真，则表示账户中有钱，阻塞其他用户存钱
  80.                         } catch (InterruptedException e) {
  81.                                 // TODO Auto-generated catch block
  82.                                 e.printStackTrace();
  83.                         }
  84.                 }
  85.                 else
  86.                 {
  87.                         System.out.println(Thread.currentThread().getName()+
  88.                                         " 存款："+depositMoney+"元");
  89.                         this.balance += depositMoney;
  90.                         System.out.println("账户余额为："+this.getBalance());
  91.                         bFlagHasMoney = true;
  92.                         notifyAll();
  93.                 }
  94.         }
  95.        
  96. }
复制代码

//DepositMoneyThread.java代码
  1. package com.wayne.practice;
  2. //定义取钱的线程
  3. public class DepositMoneyThread extends Thread {
  4.        
  5.         private Account account;
  6.         private double depositMoney;

  8.         public DepositMoneyThread(){}
  9.        
  10.         public DepositMoneyThread(String thrName,Account account,double depositMoney)
  11.         {
  12.                 super(thrName);
  13.                 this.account = account;
  14.                 this.depositMoney = depositMoney;
  15.         }
  16.        
  17.         @Override
  18.         public void run() {
  19.                 // TODO Auto-generated method stub
  20.                 for(int i = 0;i<10;i++)
  21.                         account.deposit(depositMoney);;
  22.         }
  23.        
  24. }
复制代码

//DrawMoneyThread.java代码
  1. package com.wayne.practice;
  2. //定义取钱的线程
  3. public class DrawMoneyThread extends Thread {
  4.        
  5.         private Account account;
  6.         private double drawMoney;

  8.         public DrawMoneyThread(){}
  9.        
  10.         public DrawMoneyThread(String thrName,Account account,double drawMoney)
  11.         {
  12.                 super(thrName);
  13.                 this.account = account;
  14.                 this.drawMoney = drawMoney;
  15.         }
  16.        
  17.         @Override
  18.         public void run() {
  19.                 // TODO Auto-generated method stub
  20.                 for(int i = 0;i<10;i++)
  21.                         account.draw(drawMoney);
  22.         }
  23.        
  24. }
复制代码

//AccountAppk.java代码
package com.wayne.practice;

public class AccountApp {

        public static void main(String[] args) {
                // TODO Auto-generated method stub
                Account acct = new Account("123456",0);
               
                new DrawMoneyThread("取款者", acct, 800).start();
                new DepositMoneyThread("存款者甲", acct, 800).start();
                new DepositMoneyThread("存款者乙", acct, 800).start();
                new DepositMoneyThread("存款者丙", acct, 800).start();
        }

}
作者: lostyou    时间: 2015-9-29 23:54
你这个这么多代码,需求和注释都没有怎么看啊
作者: a80C51    时间: 2015-10-1 16:31
lostyou 发表于 2015-9-29 23:54
你这个这么多代码,需求和注释都没有怎么看啊

主要是练习notifyAll的wait的用法，至于需求。其实可以自定义的。



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2