1. ReentrantLock可以完成synchronized可以完成的功能,可以代替synchronized。
2. 比synchronized灵活
- 可以用tryLock进行尝试锁定,且可以设置尝试锁定的时间。
lock.tryLock(); // 设定尝试锁定时间 lock.tryLock(1,TimeUnit.SECONDS);
- 可以使用lockInterruptibly锁定,使其可以被打断。
lock.lockInterruptibly(); // 打断 t2.interrupt();
3.可以将锁指定为公平锁。
Lock lock = new ReentrantLock(true);
4.结合Condition实现简单的阻塞队列:
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();
// 启动消费者线程
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();
}
// 启动生产者线程
for(int i = 0; i < 5; i++){
new Thread(()->{
for(int j = 0; j < 5; j++){
a.put(new Object());
}
},"P"+i).start();
}
}
}