現有乙個需求如下:
有10000張火車票,每張票都有乙個編號,同時有10個視窗對外售票,如何確保車票的正常售賣?
問題的解決辦法都是從我們最最熟悉的角度思考。程式一,我們使用乙個普通的list作為方案。
public class ticketsell_01
public static void main(string args)
}).start();}}
}
輸出結果如下,可以看到,編號0的車票被銷售了兩次。list不是同步容器,容器內的remove()等方法都無法做到原子性,因此會出現重複售票的問題,因此是不安全的:
以vector代替list作為容器。區別是,vector是同步容器,內部的方法都是同步的。但是下面的**依然會存在問題。
雖然size()方法和remove()方法本身是原子性的,其他執行緒無法打斷,但是在判斷size和remove之間的部分依然會有執行緒交叉執行的可能,這樣,雖然可以解決重複銷售的問題,但是依然會導致:arrayindexoutofbound***ception
public class ticketsell_02
public static void main(string args) catch (exception e)
system.out.println("銷售了--" + tickets.remove(0));
}}).start();}}
}
執行結果:
使用synchronized進行執行緒同步,可以有效解決邏輯問題,但是很明顯,這種方法的缺點就是效率低下。
public class ticketsell_03
public static void main(string args)
}}).start();}}
}
concurrentlinkedqueue是乙個併發佇列。但凡併發容器,其內部的方法都保證是原子性的。下面的**中poll()表示從佇列的頭部獲得乙個資料,當返回值為null時,代表這個佇列已經沒有值了。因為佇列本身不允許存null值,否則會報空指標異常,因此當返回值為null時,一定表示佇列已空(size() == 0)。佇列的底層是使用乙個叫做compareandset(cas)的技術實現的,不是加鎖的實現,因此在高併發的情況下依然可以擁有很高的效率。
public class ticketsell_04
public static void main(string args)
}).start();}}
}
Java併發程式設計實戰 總結
1.可變狀態是至關重要的。所有的併發問題都可以歸結為如何協調對併發狀態的訪問,可變狀態越少,就越容易確保執行緒安全性。2.盡量將域宣告為final型別,除非需要它們是可變的。3.不可變物件一定是執行緒安全的。不可變物件能極大地降低併發程式設計的複雜性。它們更為簡單而且安全,可以任意共享而無須使用加鎖...
java併發程式設計實戰 簡介
1 併發和並行的區別 併發 多個程式在同一時間段執行,只有乙個cpu。並行 多個程式在同一時刻執行,有多個cpu。2 執行緒帶來的風險 1 安全性問題 永遠不發生糟糕的事情 兩個或多個執行緒同時訪問乙個變數,可能會出現差錯。例如,兩個執行緒同時對乙個變數執行讀操作,從而它們得到了相同的值,違背了該變...
《Java併發程式設計實戰》 5
每當看到new thread runnable start 時,並且你希望獲得一種更靈活的執行策略時,請考慮使用excecutor來代替thread。completionservice將execute和blockingqueue的功能融合在一起。executorcompletionservice實現...