时间戳

首页 > 解决方案 > 具有不同超时的嵌套 tryLock 的 ReentrantLock，实际超时是多少？

java - 具有不同超时的嵌套 tryLock 的 ReentrantLock，实际超时是多少？

问题描述

我正在尝试通过两个调用创建一个不公平的缓冲区

  1. 向缓冲区添加值
  2. 清空缓冲区

清空队列的线程应该比添加到队列的线程具有更高的优先级。

如果缓冲区已满，我会在内部调用 empty 方法以允许队列清空。

基本思想是添加缓冲区上的锁被限制为addTimeout并且空的锁是emptyAddRatio * addTimeout 所以 add 将具有更高的优先级（假设我有更多的添加然后是空的）。

public class EmptyPriorityBuffer {
private ReentrantLock lock = new ReentrantLock(true);
private long addTimeout = 10;
private long emptyAddRatio = 5;
private int maxSize = 1000;
private LinkedBlockingDeque<Object> buffer = new LinkedBlockingDeque<>(maxSize);

public List<Object> empty() {
    try {
        lock.tryLock(addTimeout * emptyAddRatio, TimeUnit.MILLISECONDS);
        ArrayList<Object> result = new ArrayList<>();
        buffer.drainTo(result);
        return result;
    } catch (InterruptedException e) {
        e.printStackTrace();
    } finally {
        lock.unlock();
    }
    return Collections.emptyList();
}

public void add(Object object) {
    try {
        lock.tryLock(addTimeout, TimeUnit.MILLISECONDS);
        if (!buffer.offer(object)) {
            empty();
            buffer.offer(object);
        }
    } catch (InterruptedException e) {
        e.printStackTrace();
    } finally {
        lock.unlock();
    }
}

我的问题： 在缓冲区已满的情况下会发生什么。
当前线程被获取以使用 addtimeout 锁定，现在它要求使用emptyAddRatio * addTimeout的嵌套锁定，女巫比addTimeout大。emptyAddRatio * addTimeout 或addTimeout
之后线程会被中断吗？

标签： javamultithreadinglocking

解决方案

重入案例中的超时参数不会产生影响，因为您已经拥有锁。也就是说，add获取锁的调用已经（并且可能必须等待最大addTimeout毫秒。任何进一步的获取相同锁的尝试都将立即成功。

但是请注意，您需要检查lock.tryLock两种方法的返回值，empty并add确定获取锁是实际成功还是超时。在后一种情况下，您可能想要中止而不是继续。

推荐阅读