可重入鎖:鎖可以連續(xù)使用
計數(shù)器+判斷進入的線程是不是已經(jīng)鎖定的線程,如果是那就不用等待,直接使用
站在用戶的角度思考問題,與客戶深入溝通,找到龍灣網(wǎng)站設計與龍灣網(wǎng)站推廣的解決方案,憑借多年的經(jīng)驗,讓設計與互聯(lián)網(wǎng)技術結合,創(chuàng)造個性化、用戶體驗好的作品,建站類型包括:成都網(wǎng)站設計、做網(wǎng)站、成都外貿(mào)網(wǎng)站建設公司、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣、域名與空間、網(wǎng)頁空間、企業(yè)郵箱。業(yè)務覆蓋龍灣地區(qū)。
public class my {
public static void main(String[]args)
{
my m=new my();
m.test();
}
public void test()
{
synchronized(this)//第一次獲得鎖
{
while(true)
{
synchronized(this)//第二次獲得鎖,假如沒有可重入鎖,將會造成死鎖
{
System.out.println("relock");
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
手工實現(xiàn):
public class my {
Lock lock=new Lock();
public void a() throws InterruptedException
{
lock.lock();
System.out.println(lock.getCount());
b();
lock.unlock();
System.out.println(lock.getCount());
}
public void b() throws InterruptedException
{
lock.lock();
System.out.println(lock.getCount());
//..
lock.unlock();
System.out.println(lock.getCount());
}
public static void main(String[]args) throws InterruptedException
{
my m=new my();
m.a();
Thread.sleep(1000);
System.out.println(m.lock.getCount());
}
}
class Lock{
//是否占用
private boolean isLocked=false;
private Thread lockedBy=null;//存儲線程,如果是自身就不等了
private int count=0;
//使用鎖
public synchronized void lock() throws InterruptedException
{
Thread t=Thread.currentThread();
while(isLocked&&lockedBy!=t)//如果被鎖住了,且不是當前線程
{
wait();
}
isLocked=true;
lockedBy=t;
count++;
}
//釋放鎖
public synchronized void unlock()
{
if(Thread.currentThread()==lockedBy)
{
count--;
if(count==0)
{
isLocked=false;
notify();
lockedBy=null;
}
}
isLocked=false;
notify();
}
public int getCount() {
return count;
}
public void setCount(int count) {
this.count = count;
}
}