關於多執行緒安全的解決方案
在spring中預設的service是singleton的,這就造成了一個問題:在有共享變數(比如static變數,有時候我們不得不這麼做)的時候,需要考慮到該共享變數的多執行緒安全問題。
解決這個問題有幾個方法:
1.藉助支援多執行緒安全的物件建立方式。如果是static Map型別的變數,在不需要考慮併發的情況下我們可以這麼建立
private static Map<T1,T2> MY_MAP = new HashMap<T1,T2>();
但是HashMap是非執行緒安全的,大家可能會想到HashTable,HashTable使用synchonized方法實現,會造成很大的效能問題。在JDK1.5及以後的版本中新增了一個包 java.util.concurrent,這個包中的方法既能控制併發又不影響效能,這個時候應該這樣建立該Map物件:
private static Map<T1,T2> MY_MAP = new ConcurrentHashMap<T1,T2>();
這樣就從變數級別的進行了併發控制,效能幾乎不受什麼影響。
2.除此之外我們還可以藉助synchonized來進行執行緒同步,使得併發時執行緒鎖定資源排隊獲取資源,這樣能保證共享變數的多執行緒安全.具體實現方法如下:
private static Object MY_LOCK = new Object();
可以鎖定一個方法 :
public synchonized(MY_LOCK) Map<T1,T2> getMyMap(){
...
}
但是如果你只是為了保護幾個共享變數的話,沒必要整個類同步,只要針對共享變數的操作進行同步即可
private static Map<T1,T2> MY_MAP = new HashMap<T1,T2>();
public Map<T1,T2> getMyMap(){
synchonized(MY_LOCK){
MY_MAP = appService.getMyMap();
}
...
}
3.類似於synchonized,java.utils.concurrent包下lock類也可以作為物件鎖來使用,之前要匯入java.utils.concurrent.locks.ReentrantLock類檔案
private ReentrantLock myLock = new ReentrantLock();
public Map<T1,T2> getMyMap(){
myLock.lock();
try{
MY_MAP = appService.getMyMap();
}finally{
myLock.unlock();
}
...
}
這裡需要注意的是,將需要鎖住的模組放在 myLock.lock() 和myLock.unlock()語句之間,為了方便鎖的釋放,通常都將鎖放在try{}最後一定要釋放鎖。
4.synchronized 和Lock的異同。主要相同點:Lock能完成Synchronized所實現的所有功能。主要不同點:Lock有比synchronied更精確的執行緒語義和更好的效能。Synchronized會自動釋放所,而Lock一定要程式設計師手工釋放,一般都在finally子句中釋放。
java安全結束多執行緒的方式
(1)用interrupt() ;中斷執行緒就可以了
Java執行緒:執行緒安全與不安全
作為一個Java web開發人員,很少也不需要去處理執行緒,因為伺服器已經幫我們處理好了。記得大一剛學Java的時候,老師帶著我們做了一個區域網聊天室,用到了AWT、Socket、多執行緒、I/O,編寫的客戶端和伺服器,當時做出來很興奮,回學校給同學們演示,感覺自己好NB,呵呵,扯遠了。上次在百度開發者大會上看到一個提示語,自己寫的程式碼,6個月不看也是別人的程式碼,自己學的知識也同樣如此,學完的知識如果不使用或者不常常回顧,那麼還不是自己的知識。大學零零散散搞了不到四年的Java,我相信很多人都跟我一樣,JavaSE基礎沒打牢,就急忙忙、興沖沖的搞JavaEE了,然後學習一下前臺開發(html、css、javascript),有可能還搞搞jquery、extjs,再然後是Struts、hibernate、spring,然後聽說找工作得會linux、oracle,又去學,在這個過程中,是否迷失了,雖然學習面很廣,但就像《神鵰俠侶》中黃藥師評價楊過,博而不精、雜而不純,這一串下來,感覺做Java開發好難,並不是學著難,而是知識面太廣了,又要精通這個,又要精通那個,這只是我迷茫時候的想法,現在我已經找到方向了。
迴歸正題,當我們檢視JDK API的時候,總會發現一些類說明寫著,執行緒安全或者執行緒不安全,比如說StringBuilder中,有這麼一句,"將StringBuilder
的例項用於多個執行緒是不安全的。如果需要這樣的同步,則建議使用StringBuffer. ",那麼下面手動建立一個執行緒不安全的類,然後在多執行緒中使用這個類,看看有什麼效果。
Count.java:
public class Count {
private int num;
public void count() {
for(int i = 1; i <= 10; i++) {
num += i;
}
System.out.println(Thread.currentThread()。getName() + "-" + num);
}
}
在這個類中的count方法是計算1一直加到10的和,並輸出當前執行緒名和總和,我們期望的是每個執行緒都會輸出55.
ThreadTest.java:
public class ThreadTest {
public static void main(String[] args) {
Runnable runnable = new Runnable() {
Count count = new Count();
public void run() {
count.count();
}
};
for(int i = 0; i < 10; i++) {
new Thread(runnable)。start();
}
}
}
這裡啟動了10個執行緒,看一下輸出結果:
Thread-0-55
Thread-1-110
Thread-2-165
Thread-4-220
Thread-5-275
Thread-6-330
Thread-3-385
Thread-7-440
Thread-8-495
Thread-9-550
只有Thread-0執行緒輸出的結果是我們期望的,而輸出的是每次都累加的,這裡累加的原因以後的博文會說明,那麼要想得到我們期望的結果,有幾種解決方案:
1. 將Count中num變成count方法的區域性變數;
public class Count {
public void count() {
int num = 0;
for(int i = 1; i <= 10; i++) {
num += i;
}
System.out.println(Thread.currentThread()。getName() + "-" + num);
}
}
2. 將執行緒類成員變數拿到run方法中;
public class ThreadTest4 {
public static void main(String[] args) {
Runnable runnable = new Runnable() {
public void run() {
Count count = new Count();
count.count();
}
};
for(int i = 0; i < 10; i++) {
new Thread(runnable)。start();
}
}
}
3. 每次啟動一個執行緒使用不同的執行緒類,不推薦。
上述測試,我們發現,存在成員變數的類用於多執行緒時是不安全的,而變數定義在方法內是執行緒安全的。想想在使用struts1時,不推薦建立成員變數,因為action是單例的,如果建立了成員變數,就會存線上程不安全的隱患,而struts2是每一次請求都會建立一個action,就不用考慮執行緒安全的問題。