多線程 synchronized

java
public class SynchronizedDome {
public static void main(String[] args) {
Map ticketMap = new HashMap<String, Boolean>();//票池:<票編號(hào),是否已出售>
for(int i = 1; i <= 100; i++){//生成100張火車(chē)票到票池
ticketMap.put("T" + i, false);
}

//生成4名售票員
TicketSaler s1 = new TicketSaler(ticketMap, "S1");
TicketSaler s2 = new TicketSaler(ticketMap, "S2");
TicketSaler s3 = new TicketSaler(ticketMap, "S3");
TicketSaler s4 = new TicketSaler(ticketMap, "S4");

    Thread t1 =new Thread(s1);
    Thread t2 =new Thread(s2);
    Thread t3 =new Thread(s3);
    Thread t4 =new Thread(s4);

    t1.setName("T1");
    t2.setName("T2");
    t3.setName("T3");
    t4.setName("T4");

    ExecutorService service = Executors.newCachedThreadPool();

    service.execute(t1);
    service.execute(t2);
    service.execute(t3);
    service.execute(t4);

    service.shutdown();//執(zhí)行完線程池中的線程后盡快退出

}

}
class TicketSaler implements Runnable {
private Map<String, Boolean> ticketMap;//票池
private String salerName;//售票員姓名

public TicketSaler(Map<String, Boolean> ticketMap, String salerName){
    this.ticketMap = ticketMap;
    this.salerName = salerName;
}


//售票
private void saleTicket(){
    int rigter = 100;
    for(Iterator<String> it = ticketMap.keySet().iterator(); ;){
        synchronized (ticketMap)
        {
            if(it.hasNext()){
                String ticketNo = it.next();
                if(!ticketMap.get(ticketNo)){
                    System.out.println(rigter--);
                    System.out.println(salerName +":" + ticketNo + "已被售出。");
                    ticketMap.put(ticketNo, true);
                }
            }else{
                System.out.println("沒(méi)票了!?。?!");
                break;
            }
        }
    }
}
@Override
public void run() {
    saleTicket();
}

}

因?yàn)閇Java](http://lib.csdn.net/base/javase)或者C#中的線程同步與多線程的概念,只是在單個(gè)對(duì)象下 這一范圍內(nèi)的,也就是說(shuō):?jiǎn)蝹€(gè)對(duì)象下的 多線程同步 或者 死鎖。如果有下面的需求:
1,該類(lèi)只允許在同一時(shí)刻實(shí)例化(new)一次;----考慮單例模式.
2,或者只允許在同一時(shí)刻僅可存活一個(gè)對(duì)于[數(shù)據(jù)庫(kù)](http://lib.csdn.net/base/mysql)的修改 或 刪除操作;--考慮單例模式 或者 數(shù)據(jù)庫(kù)內(nèi)的事務(wù)鎖概念。

下面我們著重介紹java中的 Sychronized的用法,具體為:同步方法 與 同步塊
synchronized 關(guān)鍵字,它包括兩種用法:synchronized 方法和 synchronized 塊。
  1. synchronized 方法:通過(guò)在方法聲明中加入 synchronized關(guān)鍵字來(lái)聲明 synchronized 方法。如:
  public synchronized void accessVal(int newVal);
  synchronized 方法控制對(duì)類(lèi)成員變量的訪問(wèn):每個(gè)類(lèi)實(shí)例對(duì)應(yīng)一把鎖,每個(gè) synchronized 方法都必須獲得調(diào)用該方法的類(lèi)實(shí)例的鎖方能執(zhí)行,否則所屬線程阻塞,方法一旦執(zhí)行,就獨(dú)占該鎖,直到從該方法返回時(shí)才將鎖釋放,此后被阻塞的線程方能獲得該鎖,重新進(jìn)入可執(zhí)行狀態(tài)。這種機(jī)制確保了同一時(shí)刻對(duì)于每一個(gè)類(lèi)實(shí)例,其所有聲明為 synchronized 的成員函數(shù)中至多只有一個(gè)處于可執(zhí)行狀態(tài)(因?yàn)橹炼嘀挥幸粋€(gè)能夠獲得該類(lèi)實(shí)例對(duì)應(yīng)的鎖),從而有效避免了類(lèi)成員變量的訪問(wèn)沖突(只要所有可能訪問(wèn)類(lèi)成員變量的方法均被聲明為 synchronized)。
  在 Java 中,不光是類(lèi)實(shí)例,每一個(gè)類(lèi)也對(duì)應(yīng)一把鎖,這樣我們也可將類(lèi)的靜態(tài)成員函數(shù)聲明為 synchronized ,以控制其對(duì)類(lèi)的靜態(tài)成員變量的訪問(wèn)。
  synchronized 方法的缺陷:若將一個(gè)大的方法聲明為synchronized 將會(huì)大大影響效率,典型地,若將線程類(lèi)的方法 run() 聲明為 synchronized ,由于在線程的整個(gè)生命期內(nèi)它一直在運(yùn)行,因此將導(dǎo)致它對(duì)本類(lèi)任何 synchronized 方法的調(diào)用都永遠(yuǎn)不會(huì)成功。當(dāng)然我們可以通過(guò)將訪問(wèn)類(lèi)成員變量的代碼放到專(zhuān)門(mén)的方法中,將其聲明為 synchronized ,并在主方法中調(diào)用來(lái)解決這一問(wèn)題,但是 Java 為我們提供了更好的解決辦法,那就是 synchronized 塊。
  2. synchronized 塊:通過(guò) synchronized關(guān)鍵字來(lái)聲明synchronized 塊。語(yǔ)法如下:
  synchronized(syncObject) {
  //允許訪問(wèn)控制的代碼
  }
   synchronized 塊是這樣一個(gè)代碼塊,其中的代碼必須獲得對(duì)象 syncObject (如前所述,可以是類(lèi)實(shí)例或類(lèi))的鎖方能執(zhí)行,具體機(jī)制同前所述。由于可以針對(duì)任意代碼塊,且可任意指定上鎖的對(duì)象,故靈活性較高。
  對(duì)synchronized(this)的一些理解
  一、當(dāng)兩個(gè)并發(fā)線程訪問(wèn)同一個(gè)對(duì)象object中的這個(gè)synchronized(this)同步代碼塊時(shí),一個(gè)時(shí)間內(nèi)只能有一個(gè)線程得到執(zhí)行。另一個(gè)線程必須等待當(dāng)前線程執(zhí)行完這個(gè)代碼塊以后才能執(zhí)行該代碼塊。
  二、然而,當(dāng)一個(gè)線程訪問(wèn)object的一個(gè)synchronized(this)同步代碼塊時(shí),另一個(gè)線程仍然可以訪問(wèn)該object中的非synchronized(this)同步代碼塊。
  三、尤其關(guān)鍵的是,當(dāng)一個(gè)線程訪問(wèn)object的一個(gè)synchronized(this)同步代碼塊時(shí),其他線程對(duì)object中所有其它synchronized(this)同步代碼塊的訪問(wèn)將被阻塞。
  四、第三個(gè)例子同樣適用其它同步代碼塊。也就是說(shuō),當(dāng)一個(gè)線程訪問(wèn)object的一個(gè)synchronized(this)同步代碼塊時(shí),它就獲得了這個(gè)object的對(duì)象鎖。結(jié)果,其它線程對(duì)該object對(duì)象所有同步代碼部分的訪問(wèn)都被暫時(shí)阻塞。
  五、以上規(guī)則對(duì)其它對(duì)象鎖同樣適用
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書(shū)系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容