1. ReentrantLock可以完成synchronized可以完成的功能军拟,可以代替synchronized凛虽。
2. 比synchronized靈活
- 可以用tryLock進(jìn)行嘗試鎖定半开,且可以設(shè)置嘗試鎖定的時(shí)間。
lock.tryLock(); // 設(shè)定嘗試鎖定時(shí)間 lock.tryLock(1,TimeUnit.SECONDS);
- 可以使用lockInterruptibly鎖定,使其可以被打斷猾封。
lock.lockInterruptibly(); // 打斷 t2.interrupt();
3.可以將鎖指定為公平鎖。
Lock lock = new ReentrantLock(true);
4.結(jié)合Condition實(shí)現(xiàn)簡單的阻塞隊(duì)列:
public class App<T> {
private Lock lock = new ReentrantLock();
private Condition producer = lock.newCondition();
private Condition consumer = lock.newCondition();
private LinkedList<T> list = new LinkedList<>();
private final int max = 5;
private void put(T t) {
lock.lock();
try {
while (list.size() == max) {
producer.await();
}
list.add(t);
consumer.signalAll();
System.out.println(Thread.currentThread().getName()+"_"+list.size()+"_put");
} catch (InterruptedException e) {
e.printStackTrace();
}finally {
lock.unlock();
}
}
private T get(){
T t = null;
lock.lock();
try {
while (list.size() == 0){
consumer.await();
}
t = list.removeFirst();
producer.signalAll();
System.out.println(Thread.currentThread().getName()+"_"+list.size()+"_get");
}catch (InterruptedException e){
e.printStackTrace();
}finally {
lock.unlock();
}
return t;
}
public static void main(String[] args) {
App a = new App();
// 啟動消費(fèi)者線程
for(int i = 0; i < 5; i++){
new Thread(()->{
for(int j = 0; j < 5; j++){
a.get();
}
},"C"+i).start();
}
try {
TimeUnit.SECONDS.sleep(2);
}catch (Exception e){
e.printStackTrace();
}
// 啟動生產(chǎn)者線程
for(int i = 0; i < 5; i++){
new Thread(()->{
for(int j = 0; j < 5; j++){
a.put(new Object());
}
},"P"+i).start();
}
}
}