当前位置: 首页 > 面试题库 >

使用`LinkedBlockingQueue`可能导致空指针异常

秦滨海
2023-03-14
问题内容

我最近正在学习Java并发编程。我知道final关键字可以保证安全的发布。但是,当我阅读LinkedBlockingQueue源代码时,发现headand
last字段未使用final关键字。我发现该enqueue方法在方法中被调用put,并且该enqueue方法直接将值分配给last.next。此时,last可能是null因为last未使用声明final。我的理解正确吗?虽然lock可以保证last读写线程的安全性,但是可以lock
保证last不是一个正确的初始值null

public class LinkedBlockingQueue<E> extends AbstractQueue<E>
        implements BlockingQueue<E>, java.io.Serializable {
transient Node<E> head;
private transient Node<E> last;
public LinkedBlockingQueue(int capacity) {
        if (capacity <= 0) throw new IllegalArgumentException();
        this.capacity = capacity;
        last = head = new Node<E>(null);
    }
 private void enqueue(Node<E> node) {
        // assert putLock.isHeldByCurrentThread();
        // assert last.next == null;
        last = last.next = node;
    }

public void put(E e) throws InterruptedException {
        if (e == null) throw new NullPointerException();
        // Note: convention in all put/take/etc is to preset local var
        // holding count negative to indicate failure unless set.
        int c = -1;
        Node<E> node = new Node<E>(e);
        final ReentrantLock putLock = this.putLock;
        final AtomicInteger count = this.count;
        putLock.lockInterruptibly();
        try {
            /*
             * Note that count is used in wait guard even though it is
             * not protected by lock. This works because count can
             * only decrease at this point (all other puts are shut
             * out by lock), and we (or some other waiting put) are
             * signalled if it ever changes from capacity. Similarly
             * for all other uses of count in other wait guards.
             */
            while (count.get() == capacity) {
                notFull.await();
            }
            enqueue(node);
            c = count.getAndIncrement();
            if (c + 1 < capacity)
                notFull.signal();
        } finally {
            putLock.unlock();
        }
        if (c == 0)
            signalNotEmpty();
    }
}

问题答案:

根据此博客文章https://shipilev.net/blog/2014/safe-public-
construction/
甚至final在构造函数中写入一个属性也足以实现安全的初始化(因此,您的对象将始终被安全地发布)。并且capacity属性声明为final

简而言之,我们在以下三种情况下会产生障碍:

最后一个领域是这样写的。注意,我们并不关心实际写入哪个字段,我们在退出(initializer)方法之前无条件地发出了屏障。这意味着,如果您至少有一个final字段写操作,则final字段语义将扩展到构造函数中编写的所有其他字段。



 类似资料:
  • 我一直在youtube上学习android的自定义视图等等。在我尝试做一个表面视图(相当简单的描述在这个视频)。 我所做的事情与视频中所显示的几乎是同步的。

  • 当你点击btnChangePass,我得到错误。 我有一个错误: FATAL EXCEPTION:主进程:com.company.learn2,PID:18854java.lang.NullPointerExcture atcom.company.learn2。Heslo.change密码(Heslo.java:84)在com.company.learn2。Heslo.on点击(Heslo.jav

  • 问题内容: 有可能这可能是一个双重问题。我将String变量初始化为null。我可能会或可能不会使用一个值更新它。现在我想检查此变量是否不等于null以及我尝试执行的操作是否会得到null指针异常。空指针异常,因为它代价高昂。是否有任何有效的解决方法.TIA 问题答案: 如果您使用 你 不会 得到。 我怀疑你在做什么: 这是因为null 而引发,而不是因为null。 如果仍然无法解释,请发布您用于

  • 我已经更新了我的项目中的一些依赖关系之后,我的Hibernate配置类显示Nullpointerx的。 我将SpringDataJPA存储库与hibernate一起使用,已经超过24小时了,仍然没有找到任何关于小问题的适当解决方案。 我已经尝试过的一些解决方案:- 使用@bean(name=“entityManagerFactory”)提供bean名称 我面临的问题 波姆。xml文件 配置类 db

  • 我是Android Studio的新手,我以为我做得很好,但是昨晚遇到了一个错误,尽管我尽了最大努力在谷歌上搜索,我似乎还是无法修复。我的一个活动上的一个按钮“可能会产生java.lang.NullPointerExctive”,只是每次按下它都会失败。这可能只是在错误的地方订购一行代码等简单的事情,但是我对Android Studio太陌生了,我真的不知道我哪里出错了。 这是XML 还有清单文件

  • 我有以下方法: 租户数据库服务。findTenantById(tenantId)返回可选的: 当为null时,我希望抛出异常。相反,我看到正在抛出: 有什么帮助吗?