-
酒后略带风情2018-10-22 00:00
- 61
- 0
先附上BlockingQueue源码take()代码：
public class ArrayBlockingQueue<E> implements BlockingQueue<E> {
final ReentrantLock lock;
//构造体中初始化lock
public ArrayBlockingQueue<E>(){
//...
}
public E take() throws InterruptedException {
final ReentrantLock lock = this.lock; //疑惑
lock.lockInterruptibly();
try {
while (count == 0)
notEmpty.await();
return dequeue();
} finally {
lock.unlock();
}
}
}请问take方法中，第一行final ReentrantLock lock = this.lock，为什么要把全局字段lock先复制到一个局部变量中使用呢？？？直接使用全局final lock不可以吗（eg. this.lock.lockInterruptibly()）？？为什么要多此一举呢？
- 共 0 条
- 全部回答
-
过去、那是昨天 普通会员 1楼
在Java中，BlockingQueue是一个内置的队列类，它使用阻塞算法来处理线程的同步问题。这个类通常用于生产者和消费者模型，其中生产者将元素放入队列，消费者从队列中取出元素并执行操作。
以下是一个简单的BlockingQueue的源码示例：
```java import java.util.concurrent.BlockingQueue; import java.util.concurrent.atomic.AtomicInteger;
public class BlockingQueueExample { private static final AtomicInteger count = new AtomicInteger(0);
public static void main(String[] args) { BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(); queue.put(1); queue.put(2); queue.put(3); queue.put(4); System.out.println("Queue Size: " + queue.size()); for (int i = 0; i < 5; i++) { try { int element = queue.take(); System.out.println("Received " + element); } catch (InterruptedException e) { e.printStackTrace(); } } }} ```
在这个示例中，我们首先创建了一个BlockingQueue，并使用put方法将一些元素放入队列。然后，我们打印出队列的大小。最后，我们尝试从队列中取出5个元素，但是由于队列是阻塞的，因此需要等待相应的线程执行完队列的put操作。
BlockingQueue的主要优点是它能有效防止阻塞，因为当队列满时，新的元素需要等待，而不是立即被阻塞。这种特性使得BlockingQueue非常适合用于生产者和消费者模型。
此外，BlockingQueue还支持两个重要的属性：size和elementCount。size属性表示队列中的元素数量，而elementCount属性表示队列中的元素总数。这两个属性都是不可变的，这意味着每次调用take方法或put方法都会更新它们的值。
以上就是关于Java BlockingQueue源码学习的一个问题的答案。希望对你有所帮助。
- 扫一扫访问手机版
回答动态
- 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器更新之后。服务器里面有部分玩家要重新创建角色是怎么回事啊？预计能赚取 0积分收益
- 神奇的四哥：发布了悬赏问题函数计算不同地域的是不能用内网吧？预计能赚取 0积分收益
- 神奇的四哥：发布了悬赏问题ARMS可以创建多个应用嘛?预计能赚取 0积分收益
- 神奇的四哥：发布了悬赏问题在ARMS如何申请加入公测呀？预计能赚取 0积分收益
- 神奇的四哥：发布了悬赏问题前端小程序接入这个arms具体是如何接入监控的，这个init方法在哪里进行添加？预计能赚取 0积分收益
- 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器刚到期，是不是就不能再导出存档了呢？预计能赚取 0积分收益
- 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器的游戏版本不兼容 尝试更新怎么解决？预计能赚取 0积分收益
- 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器服务器升级以后 就链接不上了，怎么办？预计能赚取 0积分收益
- 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器转移以后服务器进不去了，怎么解决？预计能赚取 0积分收益
- 神奇的四哥：发布了悬赏问题阿里云幻兽帕鲁服务器修改参数后游戏进入不了，是什么情况？预计能赚取 0积分收益
- 回到顶部
- 回到顶部