ReentrantLock

1. ReentrantLock可以完成synchronized可以完成的功能,可以代替synchronized。
2. 比synchronized灵活

  1. 可以用tryLock进行尝试锁定,且可以设置尝试锁定的时间。
lock.tryLock();
// 设定尝试锁定时间
lock.tryLock(1,TimeUnit.SECONDS);
  1. 可以使用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();
        }
    }
}
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。