java 執行緒 (三)執行緒併發的安全性 同步程式碼塊
阿新 • • 發佈:2018-12-28
package cn.sasa.demo1; import java.util.concurrent.ExecutionException; public class ThreadDemo { public static void main(String[] args) throws InterruptedException, ExecutionException { //建立Runnable介面實現類物件 Ticket t = new Ticket(); //建立3個Thread類物件,傳遞Runnable介面實現類 Thread t0 = newThread(t); Thread t1 = new Thread(t); Thread t2 = new Thread(t); Thread t3 = new Thread(t); t0.start(); t1.start(); t2.start(); t3.start(); /** * 執行緒安全問題一般發生在: * 多執行緒併發訪問同一個資料資源 * * 沒有加同步,通過執行緒休眠,出現了安全問題 * * Thread-0 出售第 99 * Thread-1 出售第 98 * Thread-2 出售第 100 * Thread-3 出售第 97 * Thread-1 出售第 96 * Thread-0 出售第 96 * Thread-3 出售第 95 * Thread-2 出售第 94 * Thread-0 出售第 93 * Thread-1 出售第 92 * Thread-3 出售第 91 * Thread-2 出售第 91 * Thread-0 出售第 90 * Thread-1 出售第 90 * Thread-2 出售第 88 * Thread-3 出售第 89 * Thread-0 出售第 87 * Thread-1 出售第 87 ...... * * 解決安全問題: 執行緒同步 * synchronized(任意物件){ * 執行緒要操作的共享資料 * } **/ } }
package cn.sasa.demo1; public class Ticket implements Runnable { //定義出售的票源 private int ticket = 100; //同步鎖,物件監視器 //沒有鎖的執行緒不能執行,只能等 // private Object obj = new Object(); public void run(){ int flag = 100; while(flag > 0){//加入同步程式碼塊,保證執行緒安全 synchronized(obj) { if( ticket > 0){ try { Thread.sleep(200); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println(Thread.currentThread().getName()+" 出售第 "+ticket--); } flag --; } } } }