1. 程式人生 > >java 執行緒 (三)執行緒併發的安全性 同步程式碼塊

java 執行緒 (三)執行緒併發的安全性 同步程式碼塊

 

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 = new
Thread(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 --; } } } }