Lock：--------------------------鎖物件
* void lock()： 獲取鎖，
* void unlock():釋放鎖，
* ReentrantLock是Lock的實作類、
package cn.itcast_01; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; public class SellTicket implements Runnable { // 定義票 private int tickets = 100; // 定義鎖物件 private Lock lock = new ReentrantLock(); @Override public void run() { while (true) { try { // 加鎖 lock.lock(); if (tickets > 0) { try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + "正在出售第" + (tickets--) + "張票"); } } finally { // 釋放鎖 lock.unlock(); } } } }
package cn.itcast_01; /* * 雖然我們可以理解同步代碼塊和同步方法的鎖物件問題，但是我們并沒有直接看到在哪里加上了鎖，在哪里釋放了鎖， * 為了更清晰的表達如何加鎖和釋放鎖,JDK5以后提供了一個新的鎖物件Lock， * * Lock： * void lock()： 獲取鎖， * void unlock():釋放鎖， * ReentrantLock是Lock的實作類. */ public class SellTicketDemo { public static void main(String[] args) { // 創建資源物件 SellTicket st = new SellTicket(); // 創建三個視窗 Thread t1 = new Thread(st, "視窗1"); Thread t2 = new Thread(st, "視窗2"); Thread t3 = new Thread(st, "視窗3"); // 啟動執行緒 t1.start(); t2.start(); t3.start(); } }
生產者和消費者題代碼改進2并解決執行緒安全問題
【學生類】
package cn.itcast_04; public class Student { String name; int age; }
設定資訊類-----實作執行緒介面
package cn.itcast_04; public class SetThread implements Runnable { private Student s; private int x = 0; public SetThread(Student s) { this.s = s; } @Override public void run() { while (true) { synchronized (s) { if (x % 2 == 0) { s.name = "林青霞";//剛走到這里，就被別人搶到了執行權 s.age = 27; } else { s.name = "劉意"; //剛走到這里，就被別人搶到了執行權 s.age = 30; } x++; } } } }
獲取資訊類---實作執行緒介面
package cn.itcast_04; public class GetThread implements Runnable { private Student s; public GetThread(Student s) { this.s = s; } @Override public void run() { while (true) { synchronized (s) { System.out.println(s.name + "---" + s.age); } } } }
測驗類
package cn.itcast_04; /* * 分析： * 資源類：Student * 設定學生資料:SetThread(生產者) * 獲取學生資料：GetThread(消費者) * 測驗類:StudentDemo * * 問題1：按照思路寫代碼，發現資料每次都是:null---0 * 原因：我們在每個執行緒中都創建了新的資源,而我們要求的時候設定和獲取執行緒的資源應該是同一個 * 如何實作呢? * 在外界把這個資料創建出來，通過構造方法傳遞給其他的類，---讓其使用同一個資源物件 * * 問題2：為了資料的效果好一些，我加入了回圈和判斷，給出不同的值,這個時候產生了新的問題 * A:同一個資料出現多次 * B:姓名和年齡不匹配 * 原因： * A:同一個資料出現多次 * CPU的一點點時間片的執行權，就足夠你執行很多次， * B:姓名和年齡不匹配 * 執行緒運行的隨機性 * 執行緒安全問題： * A:是否是多執行緒環境 是 * B:是否有共享資料 是 * C:是否有多條陳述句操作共享資料 是 * 解決方案： * 加鎖， * 注意： * A:不同種類的執行緒都要加鎖， * B:不同種類的執行緒加的鎖必須是同一把， */ public class StudentDemo { public static void main(String[] args) { //創建資源 Student s = new Student(); //設定和獲取的類 SetThread st = new SetThread(s); GetThread gt = new GetThread(s); //執行緒類 Thread t1 = new Thread(st); Thread t2 = new Thread(gt); //啟動執行緒 t1.start(); t2.start(); } }
生產者和消費者之等待喚醒機制代碼實作
學生類
package cn.itcast_05; public class Student { String name; int age; boolean flag; // 默認情況是沒有資料，如果是true，說明有資料 }
設定學生類---執行緒實作
package cn.itcast_05; public class SetThread implements Runnable { private Student s; private int x = 0; public SetThread(Student s) { this.s = s; } @Override public void run() { while (true) { synchronized (s) { //判斷有沒有 if(s.flag){ try { s.wait(); //t1等著，釋放鎖 } catch (InterruptedException e) { e.printStackTrace(); } } if (x % 2 == 0) { s.name = "林青霞"; s.age = 27; } else { s.name = "劉意"; s.age = 30; } x++; //x=1 //修改標記 s.flag = true; //喚醒執行緒 s.notify(); //喚醒t2,喚醒并不表示你立馬可以執行，必須還得搶CPU的執行權， } //t1有，或者t2有 } } }
獲取資訊--學生類----執行緒實作
package cn.itcast_05; public class GetThread implements Runnable { private Student s; public GetThread(Student s) { this.s = s; } @Override public void run() { while (true) { synchronized (s) { if(!s.flag){ try { s.wait(); //t2就等待了，立即釋放鎖，將來醒過來的時候，是從這里醒過來的時候 } catch (InterruptedException e) { e.printStackTrace(); } } System.out.println(s.name + "---" + s.age); //林青霞---27 //劉意---30 //修改標記 s.flag = false; //喚醒執行緒 s.notify(); //喚醒t1 } } } }
測驗類
等待喚醒：
* Object類中提供了三個方法：
* wait():等待
* notify():喚醒單個執行緒
* notifyAll():喚醒所有執行緒
package cn.itcast_05; /* * 分析： * 資源類：Student * 設定學生資料:SetThread(生產者) * 獲取學生資料：GetThread(消費者) * 測驗類:StudentDemo * * 問題1：按照思路寫代碼，發現資料每次都是:null---0 * 原因：我們在每個執行緒中都創建了新的資源,而我們要求的時候設定和獲取執行緒的資源應該是同一個 * 如何實作呢? * 在外界把這個資料創建出來，通過構造方法傳遞給其他的類， * * 問題2：為了資料的效果好一些，我加入了回圈和判斷，給出不同的值,這個時候產生了新的問題 * A:同一個資料出現多次 * B:姓名和年齡不匹配 * 原因： * A:同一個資料出現多次 * CPU的一點點時間片的執行權，就足夠你執行很多次， * B:姓名和年齡不匹配 * 執行緒運行的隨機性 * 執行緒安全問題： * A:是否是多執行緒環境 是 * B:是否有共享資料 是 * C:是否有多條陳述句操作共享資料 是 * 解決方案： * 加鎖， * 注意： * A:不同種類的執行緒都要加鎖， * B:不同種類的執行緒加的鎖必須是同一把， * * 問題3:雖然資料安全了，但是呢，一次一大片不好看，我就想依次的一次一個輸出， * 如何實作呢? * 通過Java提供的等待喚醒機制解決， * * 等待喚醒： * Object類中提供了三個方法： * wait():等待 * notify():喚醒單個執行緒 * notifyAll():喚醒所有執行緒 * 為什么這些方法不定義在Thread類中呢? * 這些方法的呼叫必須通過鎖物件呼叫，而我們剛才使用的鎖物件是任意鎖物件， * 所以，這些方法必須定義在Object類中， */ public class StudentDemo { public static void main(String[] args) { //創建資源 Student s = new Student(); //設定和獲取的類 SetThread st = new SetThread(s); GetThread gt = new GetThread(s); //執行緒類 Thread t1 = new Thread(st); Thread t2 = new Thread(gt); //啟動執行緒 t1.start(); t2.start(); } }
執行緒的狀態轉換圖及執行情況
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/456104.html
標籤：Java
上一篇：輸入/輸出流