摘要：本人郵箱歡迎轉(zhuǎn)載轉(zhuǎn)載請(qǐng)注明網(wǎng)址代碼已經(jīng)全部托管有需要的同學(xué)自行下載引言多線(xiàn)程如果設(shè)計(jì)的不合理的話(huà)很可能就會(huì)出現(xiàn)死鎖當(dāng)兩個(gè)或者多個(gè)線(xiàn)程同事想要去獲取共享資源的鎖時(shí)但每個(gè)線(xiàn)程都要等其他線(xiàn)程把他們各自的鎖給釋放才能繼續(xù)運(yùn)行這就是死鎖出現(xiàn)死鎖必須具
本人郵箱:
歡迎轉(zhuǎn)載,轉(zhuǎn)載請(qǐng)注明網(wǎng)址 http://blog.csdn.net/tianshi_kco
github: https://github.com/kco1989/kco
代碼已經(jīng)全部托管github有需要的同學(xué)自行下載
引言
多線(xiàn)程如果設(shè)計(jì)的不合理的話(huà),很可能就會(huì)出現(xiàn)死鎖.當(dāng)兩個(gè)或者多個(gè)線(xiàn)程同事想要去獲取共享資源的鎖時(shí),但每個(gè)線(xiàn)程都要等其他線(xiàn)程把他們各自的鎖給釋放,才能繼續(xù)運(yùn)行,這就是死鎖.出現(xiàn)死鎖必須具備以下幾點(diǎn)
要有兩個(gè)或兩個(gè)以上的線(xiàn)程
至少有兩個(gè)共享資源的鎖
至少存在兩個(gè)線(xiàn)程各自擁有一個(gè)鎖
現(xiàn)在這兩個(gè)線(xiàn)程在等待獲取彼此的鎖,這就出現(xiàn)死鎖了
比如Thread1
synchronized(A){
//Thread1 執(zhí)行到這里
synchronized(B){
...
}
}
Thread2
synchronized(B){
//Thread2 執(zhí)行到這里
synchronized(A){
...
}
}
以上這種情況就是死鎖,如果是兩個(gè)線(xiàn)程出現(xiàn)死鎖,問(wèn)題可能還比較好找.更復(fù)雜是有多個(gè)線(xiàn)程,比如線(xiàn)程n各自擁有鎖n,然后線(xiàn)程1到線(xiàn)程n-1,正在請(qǐng)求獲取鎖n+1,而線(xiàn)程n正在請(qǐng)求獲取鎖1,這樣也或出現(xiàn)死鎖,而且還更難被發(fā)現(xiàn).
例子
我們要看一個(gè)例子
public class Demo1 {
public static void main(String[] args) {
Object bigGate = new Object();
Object smallGate = new Object();
new Thread(new Runnable() {
@Override
public void run() {
String name = Thread.currentThread().getName();
synchronized (bigGate){
System.out.println(name + ":我把大門(mén)給鎖了...然后我休息一下...");
try {
Thread.sleep(200);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(name + ":我現(xiàn)在要進(jìn)入小門(mén).....");
synchronized (smallGate){
System.out.println(name + ":我永遠(yuǎn)都進(jìn)不來(lái)啊.....");
}
}
}
},"小明").start();
new Thread(new Runnable() {
@Override
public void run() {
String name = Thread.currentThread().getName();
synchronized (smallGate){
System.out.println(name + ":我把小門(mén)給鎖了...然后我休息一下...");
try {
Thread.sleep(200);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(name + ":我現(xiàn)在要進(jìn)入大門(mén).....");
synchronized (bigGate){
System.out.println(name + ":我永遠(yuǎn)都進(jìn)不來(lái)啊.....");
}
}
}
},"小紅").start();
}
}
運(yùn)行結(jié)果
小明我把大門(mén)給鎖了...然后我休息一下...
小紅我把小門(mén)給鎖了...然后我休息一下...
小明:我現(xiàn)在要進(jìn)入小門(mén).....
小紅:我現(xiàn)在要進(jìn)入大門(mén).....
//然后程序到這里就一直不動(dòng)了.....
解決辦法
鎖的順序,讓兩個(gè)線(xiàn)程獲取鎖的順序是一直,則不會(huì)出現(xiàn)死鎖
public class Demo2 {
public static void main(String[] args) {
Object bigGate = new Object();
Object smallGate = new Object();
new Thread(new Runnable() {
@Override
public void run() {
String name = Thread.currentThread().getName();
synchronized (bigGate){
System.out.println(name + ":我把大門(mén)給鎖了...然后我休息一下...");
try {
Thread.sleep(200);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(name + ":我現(xiàn)在要進(jìn)入小門(mén).....");
synchronized (smallGate){
System.out.println(name + ":我終于進(jìn)來(lái)了.....");
}
}
}
},"小明").start();
new Thread(new Runnable() {
@Override
public void run() {
String name = Thread.currentThread().getName();
synchronized (bigGate){
System.out.println(name + ":我把大門(mén)給鎖了...然后我休息一下...");
try {
Thread.sleep(200);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(name + ":我現(xiàn)在要進(jìn)入小門(mén).....");
synchronized (smallGate){
System.out.println(name + ":我終于進(jìn)來(lái)了.....");
}
}
}
},"小紅").start();
}
}
運(yùn)行結(jié)果:
小明:我把大門(mén)給鎖了...然后我休息一下...
小明:我現(xiàn)在要進(jìn)入小門(mén).....
小明:我終于進(jìn)來(lái)了.....
小紅:我把大門(mén)給鎖了...然后我休息一下...
小紅:我現(xiàn)在要進(jìn)入小門(mén).....
小紅:我終于進(jìn)來(lái)了.....
在獲取鎖的時(shí)候加超時(shí)時(shí)間,這里我們用之前學(xué)的Lock來(lái)做例子
public class Demo3 {
public static void main(String[] args) {
Lock bigGate = new ReentrantLock();
Lock smallGate = new ReentrantLock();
Random random = new Random();
new Thread(new Runnable() {
@Override
public void run() {
String name = Thread.currentThread().getName();
bigGate.lock();
try {
System.out.println(name + ":我把大門(mén)給鎖了...然后我休息一下...");
Thread.sleep(100);
System.out.println(name + ":我現(xiàn)在要進(jìn)入小門(mén).....");
if(smallGate.tryLock(random.nextInt(500), TimeUnit.MILLISECONDS)){
try {
System.out.println(name + ":我終于進(jìn)來(lái)了.....");
}finally {
smallGate.unlock();
}
}else{
System.out.println(name + ":我進(jìn)不去小門(mén),算了,不進(jìn)了...");
}
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
bigGate.unlock();
}
}
},"小明").start();
new Thread(new Runnable() {
@Override
public void run() {
String name = Thread.currentThread().getName();
smallGate.lock();
try {
System.out.println(name + ":我把小門(mén)給鎖了...然后我休息一下...");
Thread.sleep(100);
System.out.println(name + ":我現(xiàn)在要進(jìn)入大門(mén).....");
if(bigGate.tryLock(random.nextInt(500), TimeUnit.MILLISECONDS)){
try {
System.out.println(name + ":我終于進(jìn)來(lái)了.....");
}finally {
bigGate.unlock();
}
}else{
System.out.println(name + ":我進(jìn)不去大門(mén),算了,不進(jìn)了...");
}
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
smallGate.unlock();
}
}
},"小紅").start();
}
}
運(yùn)行結(jié)果:
小明:我把大門(mén)給鎖了...然后我休息一下...
小紅:我把小門(mén)給鎖了...然后我休息一下...
小明:我現(xiàn)在要進(jìn)入小門(mén).....
小紅:我現(xiàn)在要進(jìn)入大門(mén).....
小紅:我進(jìn)不去大門(mén),算了,不進(jìn)了...
小明:我終于進(jìn)來(lái)了.....
這樣也可以保證不會(huì)出現(xiàn)死鎖.
打賞
如果覺(jué)得我的文章寫(xiě)的還過(guò)得去的話(huà),有錢(qián)就捧個(gè)錢(qián)場(chǎng),沒(méi)錢(qián)給我捧個(gè)人場(chǎng)(幫我點(diǎn)贊或推薦一下)
文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/67041.html
