Java怎么使用Condition控制線程通信

這篇文章給大家分享的是有關(guān)Java怎么使用Condition控制線程通信的內(nèi)容。小編覺得挺實用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

具體如下：

一 點睛

當使用Lock對象來保證同步時，Java提供了一個Condition類來保持協(xié)調(diào)，使用Condition可以讓那些已經(jīng)得到Lock對象、卻無法繼續(xù)執(zhí)行的線程釋放Lock對象，Condtion對象也可以喚醒其他處于等待的線程。

Condition 將同步監(jiān)視鎖方法（wait、notify 和 notifyAll）分解成截然不同的對象，以便通過將這些對象與Lock對象組合使用，為每個對象提供多個等待集（wait-set）。在這種情況下，Lock 替代了同步方法或同步代碼塊，Condition替代了同步監(jiān)視鎖的功能。

Condition實例實質(zhì)上被綁定在一個Lock對象上。要獲得特定Lock實例的Condition實例，調(diào)用Lock對象newCondition()方法即可。Condtion類提供了如下三個方法：

await()：類似于隱式同步監(jiān)視器上的wait()方法，導(dǎo)致當前線程等待，直到其他線程調(diào)用該Condtion的signal ()方法或signalAll ()方法來喚醒該線程。該await方法有更多變體：long awaitNanos(long nanosTimeout)、void awaitUninterruptibly()、awaitUntil(Date deadline)等，可以完成更豐富的等待操作。

signal ()：喚醒在此Lock對象上等待的單個線程。如果所有線程都在該Lock對象上等待，則會選擇喚醒其中一個線程。選擇是任意性的。只有當前線程放棄對該Lock對象的鎖定后（使用await()方法），才可以執(zhí)行被喚醒的線程。

signalAll()：喚醒在此Lock對象上等待的所有線程。只有當前線程放棄對該該Lock對象的鎖定后，才可以執(zhí)行被喚醒的線程。

二 代碼

1 Account類

public class Account{   // 顯式定義Lock對象   private final Lock lock = new ReentrantLock();   // 獲得指定Lock對象對應(yīng)的Condition   private final Condition cond = lock.newCondition();   // 封裝賬戶編號、賬戶余額的兩個成員變量   private String accountNo;   private double balance;   // 標識賬戶中是否已有存款的旗標   private boolean flag = false;   public Account(){}   // 構(gòu)造器   public Account(String accountNo , double balance)   {      this.accountNo = accountNo;      this.balance = balance;   }   // accountNo的setter和getter方法   public void setAccountNo(String accountNo)   {      this.accountNo = accountNo;   }   public String getAccountNo()   {      return this.accountNo;   }   // 因此賬戶余額不允許隨便修改，所以只為balance提供getter方法，   public double getBalance()   {      return this.balance;   }   public void draw(double drawAmount)   {      // 加鎖      lock.lock();      try      {        // 如果flag為假，表明賬戶中還沒有人存錢進去，取錢方法阻塞        if (!flag)        {           cond.await();        }        else        {           // 執(zhí)行取錢           System.out.println(Thread.currentThread().getName()              + " 取錢:" + drawAmount);           balance -= drawAmount;           System.out.println("賬戶余額為：" + balance);           // 將標識賬戶是否已有存款的旗標設(shè)為false。           flag = false;           // 喚醒其他線程           cond.signalAll();        }      }      catch (InterruptedException ex)      {        ex.printStackTrace();      }      // 使用finally塊來釋放鎖      finally      {        lock.unlock();      }   }   public void deposit(double depositAmount)   {      lock.lock();      try      {        // 如果flag為真，表明賬戶中已有人存錢進去，則存錢方法阻塞        if (flag)       // ①        {           cond.await();        }        else        {           // 執(zhí)行存款           System.out.println(Thread.currentThread().getName()              + " 存款:" + depositAmount);           balance += depositAmount;           System.out.println("賬戶余額為：" + balance);           // 將表示賬戶是否已有存款的旗標設(shè)為true           flag = true;           // 喚醒其他線程           cond.signalAll();        }      }      catch (InterruptedException ex)      {        ex.printStackTrace();      }      // 使用finally塊來釋放鎖      finally      {        lock.unlock();      }   }   // 下面兩個方法根據(jù)accountNo來重寫hashCode()和equals()方法   public int hashCode()   {      return accountNo.hashCode();   }   public boolean equals(Object obj)   {      if(this == obj)        return true;      if (obj !=null        && obj.getClass() == Account.class)      {        Account target = (Account)obj;        return target.getAccountNo().equals(accountNo);      }      return false;   }}

2 DrawThread線程類

public class DrawThread extends Thread{   // 模擬用戶賬戶   private Account account;   // 當前取錢線程所希望取的錢數(shù)   private double drawAmount;   public DrawThread(String name , Account account      , double drawAmount)   {      super(name);      this.account = account;      this.drawAmount = drawAmount;   }   // 重復(fù)100次執(zhí)行取錢操作   public void run()   {      for (int i = 0 ; i < 100 ; i++ )      {        account.draw(drawAmount);      }   }}

3 DepositThread線程類

public class DepositThread extends Thread{   // 模擬用戶賬戶   private Account account;   // 當前取錢線程所希望存款的錢數(shù)   private double depositAmount;   public DepositThread(String name , Account account      , double depositAmount)   {      super(name);      this.account = account;      this.depositAmount = depositAmount;   }   // 重復(fù)100次執(zhí)行存款操作   public void run()   {      for (int i = 0 ; i < 100 ; i++ )      {        account.deposit(depositAmount);      }   }}

4 測試類

public class DrawTest{   public static void main(String[] args)   {      // 創(chuàng)建一個賬戶      Account acct = new Account("1234567" , 0);      new DrawThread("取錢者" , acct , 800).start();      new DepositThread("存款者甲" , acct , 800).start();      new DepositThread("存款者乙" , acct , 800).start();      new DepositThread("存款者丙" , acct , 800).start();   }}

三 運行結(jié)果

......存款者丙 存款:800.0賬戶余額為：800.0取錢者 取錢:800.0賬戶余額為：0.0存款者甲 存款:800.0賬戶余額為：800.0取錢者 取錢:800.0賬戶余額為：0.0存款者丙 存款:800.0賬戶余額為：800.0取錢者 取錢:800.0賬戶余額為：0.0存款者甲 存款:800.0賬戶余額為：800.0取錢者 取錢:800.0賬戶余額為：0.0存款者丙 存款:800.0賬戶余額為：800.0取錢者 取錢:800.0賬戶余額為：0.0存款者甲 存款:800.0賬戶余額為：800.0

感謝各位的閱讀！關(guān)于“Java怎么使用Condition控制線程通信”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，讓大家可以學到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！