我不熟悉线程和并发编程。我正在寻找一个会导致死锁的简单代码片段,它是:
public class TestLock {
private static class fun {
int a,b;
void read() {System.out.println(a+b);}
void write(int a,int b) {this.a=a;this.b=b;}
}
public static void main (String[] args) throws java.lang.Exception {
final fun d1=new fun();
final fun d2=new fun();
Thread t1=new Thread() {
public void run() {
for(int i=0;i<5;i++) {
synchronized(d2) {
d2.read();
try {
Thread.sleep(50);
} catch (Exception ex) {
ex.printStackTrace();
}
synchronized(d1) {
d1.write(i, i);
}
}
}
};
Thread t2=new Thread() {
public void run() {
for(int i=0;i<5;i++) {
synchronized(d1) {
d1.read();
try {
Thread.sleep(50);
} catch (Exception ex) {
ex.printStackTrace();
}
synchronized(d2) {
d2.write(i, i);
}
}
}
}
};
t1.start();
t2.start();
}
}
现在我想知道如何转换这个例子,使用ReentrantLock而不是synchronized,但我不知道如何:fun需要有一个ReentrantLock属性才能有像
这样的东西Thread t1=new Thread() {
public void run() {
for(int i=0;i<5;i++) {
if(d2.lock.tryLock()) {
try {d1.read();Thread.sleep(50);} catch(Exception e) {e.printStackTrace();} finally {d1.lock.unlock();}
if(d2.lock.tryLock()) {
try {d2.write(i, i);} catch(Exception e) {e.printStackTrace();} finally {d2.lock.unlock();}
}
}
}
}
};
使用ReentrantLocks转换示例实际上意味着使用两个锁:一个与d1
相关联,另一个与d2
相关联。
并且您将通过调用lockX.lock()
来替换dX
上同步块中的每个入口,并且通过调用lockX.unlock() '来替换dX
上同步块中的任何出口。
使用tryLock()
违背了这个目的,因为如果无法获得锁,它会返回而不是等待。