王豔 201771010127《面向對象程序設計（java）》第十七週學習總結

時間 2019-11-30

標籤面向對象程序設計（java）第十七學習總結欄目軟件設計简体版

原文原文鏈接

實驗十七 線程同步控制java

實驗時間 2018-12-10編程

1、理論部分多線程

1.線程同步：多線程併發運行不肯定性問題解決方案：引入線程同步機制，使得另外一線程要使用該方法，就只能等待。併發

解決方案：dom

1）鎖對象與條件對象ide

有關鎖對象和條件對象的關鍵要點:學習

➢ 鎖用來保護代碼片斷，保證任什麼時候刻只能有一個線程執行被保護的代碼。測試

➢ 鎖管理試圖進入被保護代碼段的線程。this

➢ 鎖可擁有一個或多個相關條件對象。spa

➢ 每一個條件對象管理那些已經進入被保護的代碼段但還不能運行的線程。

2）synchronized關鍵字

某個類內方法用synchronized 修飾後，該方法被稱爲同步方法；

只要某個線程正在訪問同步方法，其餘線程欲要訪問同步方法就被阻塞，直至線程從同步方法返回前喚醒被阻塞線程，其餘線程方可能進入同步方法。

一個線程在使用的同步方法中時，可能根據問題的須要，必須使用wait()方法使本線程等待，暫時讓出CPU的使用權，並容許其它線程使用這個同步方法。

線程若是用完同步方法，應當執行notifyAll()方法通知全部因爲使用這個同步方法而處於等待的線程結束等待。

2、實驗部分

1、實驗目的與要求

(1) 掌握線程同步的概念及實現技術；

(2) 線程綜合編程練習

2、實驗內容和步驟

實驗1：測試程序並進行代碼註釋。

測試程序1：

l 在Elipse環境下調試教材651頁程序14-7，結合程序運行結果理解程序；

掌握利用鎖對象和條件對象實現的多線程同步技術。

程序以下：

package test2;

/**
 * This program shows how multiple threads can safely access a data structure.
 * @version 1.31 2015-06-21
 * @author Cay Horstmann
 */
public class SynchBankTest
{
   public static final int NACCOUNTS = 100;
   public static final double INITIAL_BALANCE = 1000;
   public static final double MAX_AMOUNT = 1000;
   public static final int DELAY = 10;
   
   public static void main(String[] args)
   {
      Bank bank = new Bank(NACCOUNTS, INITIAL_BALANCE);
      for (int i = 0; i < NACCOUNTS; i++)
      {
         int fromAccount = i;
         Runnable r = () -> {
            try
            {
               while (true)
               {
                  int toAccount = (int) (bank.size() * Math.random());
                  double amount = MAX_AMOUNT * Math.random();
                  bank.transfer(fromAccount, toAccount, amount);
                  Thread.sleep((int) (DELAY * Math.random()));
               }
            }
            catch (InterruptedException e)
            {
            }            
         };
         Thread t = new Thread(r);
         t.start();
      }
   }
}

package test2;

import java.util.*;
import java.util.concurrent.locks.*;

/**
 * A bank with a number of bank accounts that uses locks for serializing access.
 * @version 1.30 2004-08-01
 * @author Cay Horstmann
 */
public class Bank
{
   private final double[] accounts;
   private Lock bankLock;
   private Condition sufficientFunds;

   /**
    * Constructs the bank.
    * @param n the number of accounts
    * @param initialBalance the initial balance for each account
    */
   public Bank(int n, double initialBalance)
   {
      accounts = new double[n];
      Arrays.fill(accounts, initialBalance);
      bankLock = new ReentrantLock();
      sufficientFunds = bankLock.newCondition();
   }

   /**
    * Transfers money from one account to another.
    * @param from the account to transfer from
    * @param to the account to transfer to
    * @param amount the amount to transfer
    */
   public void transfer(int from, int to, double amount) throws InterruptedException
   {
      bankLock.lock();
      try
      {
         while (accounts[from] < amount)
            sufficientFunds.await();
         System.out.print(Thread.currentThread());
         accounts[from] -= amount;
         System.out.printf(" %10.2f from %d to %d", amount, from, to);
         accounts[to] += amount;
         System.out.printf(" Total Balance: %10.2f%n", getTotalBalance());
         sufficientFunds.signalAll();
      }
      finally
      {
         bankLock.unlock();
      }
   }

   /**
    * Gets the sum of all account balances.
    * @return the total balance
    */
   public double getTotalBalance()
   {
      bankLock.lock();
      try
      {
         double sum = 0;

         for (double a : accounts)
            sum += a;

         return sum;
      }
      finally
      {
         bankLock.unlock();
      }
   }

   /**
    * Gets the number of accounts in the bank.
    * @return the number of accounts
    */
   public int size()
   {
      return accounts.length;
   }
}

程序運行結果以下：

測試程序2：

l 在Elipse環境下調試教材655頁程序14-8，結合程序運行結果理解程序；

l 掌握synchronized在多線程同步中的應用。

程序以下：

package test2;

/**
 * This program shows how multiple threads can safely access a data structure,
 * using synchronized methods.
 * @version 1.31 2015-06-21
 * @author Cay Horstmann
 */
public class SynchBankTest2
{
   public static final int NACCOUNTS = 100;
   public static final double INITIAL_BALANCE = 1000;
   public static final double MAX_AMOUNT = 1000;
   public static final int DELAY = 10;

   public static void main(String[] args)
   {
      Bank bank = new Bank(NACCOUNTS, INITIAL_BALANCE);
      for (int i = 0; i < NACCOUNTS; i++)
      {
         int fromAccount = i;
         Runnable r = () -> {
            try
            {
               while (true)
               {
                  int toAccount = (int) (bank.size() * Math.random());
                  double amount = MAX_AMOUNT * Math.random();
                  bank.transfer(fromAccount, toAccount, amount);
                  Thread.sleep((int) (DELAY * Math.random()));
               }
            }
            catch (InterruptedException e)
            {
            }
         };
         Thread t = new Thread(r);
         t.start();
      }
   }
}

package test2;

import java.util.*;
import java.util.concurrent.locks.*;

/**
 * A bank with a number of bank accounts that uses locks for serializing access.
 * @version 1.30 2004-08-01
 * @author Cay Horstmann
 */
public class Bank
{
   private final double[] accounts;
   private Lock bankLock;
   private Condition sufficientFunds;

   /**
    * Constructs the bank.
    * @param n the number of accounts
    * @param initialBalance the initial balance for each account
    */
   public Bank(int n, double initialBalance)
   {
      accounts = new double[n];
      Arrays.fill(accounts, initialBalance);
      bankLock = new ReentrantLock();
      sufficientFunds = bankLock.newCondition();
   }

   /**
    * Transfers money from one account to another.
    * @param from the account to transfer from
    * @param to the account to transfer to
    * @param amount the amount to transfer
    */
   public void transfer(int from, int to, double amount) throws InterruptedException
   {
      bankLock.lock();
      try
      {
         while (accounts[from] < amount)
            sufficientFunds.await();
         System.out.print(Thread.currentThread());
         accounts[from] -= amount;
         System.out.printf(" %10.2f from %d to %d", amount, from, to);
         accounts[to] += amount;
         System.out.printf(" Total Balance: %10.2f%n", getTotalBalance());
         sufficientFunds.signalAll();
      }
      finally
      {
         bankLock.unlock();
      }
   }

   /**
    * Gets the sum of all account balances.
    * @return the total balance
    */
   public double getTotalBalance()
   {
      bankLock.lock();
      try
      {
         double sum = 0;

         for (double a : accounts)
            sum += a;

         return sum;
      }
      finally
      {
         bankLock.unlock();
      }
   }

   /**
    * Gets the number of accounts in the bank.
    * @return the number of accounts
    */
   public int size()
   {
      return accounts.length;
   }
}

程序運行結果：

測試程序3：

l 在Elipse環境下運行如下程序，結合程序運行結果分析程序存在問題；

l 嘗試解決程序中存在問題。

package test2;
class Cbank
{
     private static int s=2000;
     public  static void sub(int m)
     {
           int temp=s;
           temp=temp-m;
          try {
                 Thread.sleep((int)(1000*Math.random()));
               }
           catch (InterruptedException e)  {              }
              s=temp;
              System.out.println("s="+s);
          }
    }


class Customer extends Thread
{
  public void run()
  {
   for( int i=1; i<=4; i++)
     Cbank.sub(100);
    }
 }
public class Thread3
{
 public static void main(String args[])
  {
   Customer customer1 = new Customer();
   Customer customer2 = new Customer();
   customer1.start();
   customer2.start();
  }
}

程序運行後如圖：

分析程序，輸出結果應爲1900—1200，而控制檯上顯示結果有重複。由於沒有對程序加上鎖功能。修改後程序以下：

package test2;
class Cbank
{
     private static int s=2000;
     public synchronized static void sub(int m)
     {
           int temp=s;
           temp=temp-m;
          try {
                 Thread.sleep((int)(1000*Math.random()));
               }
           catch (InterruptedException e)  {              }
              s=temp;
              System.out.println("s="+s);
          }
    }


class Customer extends Thread
{
  public void run()
  {
   for( int i=1; i<=4; i++)
     Cbank.sub(100);
    }
 }
public class Thread3
{
 public static void main(String args[])
  {
   Customer customer1 = new Customer();
   Customer customer2 = new Customer();
   customer1.start();
   customer2.start();
  }
}

程序運行結果以下：

實驗2 編程練習

利用多線程及同步方法，編寫一個程序模擬火車票售票系統，共3個窗口，賣10張票，程序輸出結果相似（程序輸出不惟一，能夠是其餘相似結果）。

Thread-0窗口售：第1張票

Thread-0窗口售：第2張票

Thread-1窗口售：第3張票

Thread-2窗口售：第4張票

Thread-2窗口售：第5張票

Thread-1窗口售：第6張票

Thread-0窗口售：第7張票

Thread-2窗口售：第8張票

Thread-1窗口售：第9張票

Thread-0窗口售：第10張票

程序以下：

package test2;

public class Demo {
    public static void main(String[] args) {
        Mythread mythread = new Mythread();
        Thread ticket1 = new Thread(mythread);
        Thread ticket2 = new Thread(mythread);
        Thread ticket3 = new Thread(mythread);
        ticket1.start();
        ticket2.start();
        ticket3.start();
    }
}

class Mythread implements Runnable {
    int ticket = 1;
    boolean flag = true;

    @Override
    public void run() {
        while (flag) {
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

            synchronized (this) {
                if (ticket <= 10) {
                    System.out.println(Thread.currentThread().getName() + "窗口售：第" + ticket + "張票");
                    ticket++;
                }
                if (ticket > 10) {
                    flag = false;
                }
            }

        }
    }

}

程序運行結果以下：

三:實驗總結

這周繼續學習了有關線程的知識，主要學習了有關線程同步的問題。線程同步主要是爲了解決多線程併發運行不肯定性問題，使得多個線程中在一個線程使用某種方法時候，另外一線程要使用該方法，就只能等待。實驗課上，老師和學長經過演示具體的例子給咱們展示了多線程中在不加鎖時會出現的狀況，讓咱們對線程同步有了更加清晰地認識。雖然不少地方仍是不太懂仍是存在很大的問題，可是實驗課上講的內容聽得比較清晰，課後本身再運行試驗時也有了更深的體會。