栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

如何使用ConcurrentLinkedQueue?

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

如何使用ConcurrentLinkedQueue?

不,方法不需要同步,也不需要定义任何方法。它们已经在ConcurrentlinkedQueue中,只需使用它们即可。ConcurrentlinkedQueue在内部完成您需要的所有锁定和其他操作;您的生产者将数据添加到队列中,而消费者则对其进行轮询。

首先,创建您的队列:

Queue<YourObject> queue = new ConcurrentlinkedQueue<YourObject>();

现在,无论您在哪里创建生产者/消费者对象,都将其传递到队列中,以便它们有放置对象的位置(您可以为此使用setter,但是我更喜欢在构造函数中执行这种操作):

YourProducer producer = new YourProducer(queue);

和:

YourConsumer consumer = new YourConsumer(queue);

并在您的生产者中添加一些东西:

queue.offer(myObject);

并在您的使用者中取出东西(如果队列为空,则poll()将返回null,因此进行检查):

YourObject myObject = queue.poll();

有关更多信息,请参见Javadoc。

编辑:

如果需要阻止等待队列不为空,则可能要使用linkedBlockingQueue,并使用take()方法。但是,linkedBlockingQueue具有最大容量(默认为Integer.MAX_VALUE,超过20亿),因此根据您的具体情况可能合适,也可能不合适。

如果只有一个线程将材料放入队列,而另一个线程将材料从队列中取出,则ConcurrentlinkedQueue可能会过大。当您可能有数百甚至数千个线程同时访问队列时,它的作用更大。您的需求可能会满足:

Queue<YourObject> queue = Collections.synchronizedList(new linkedList<YourObject>());

这样做的好处是它锁定实例(队列),因此您可以在队列上进行同步以确保复合操作的原子性(如Jared所述)。您不能使用ConcurrentlinkedQueue来执行此操作,因为所有操作都是在不锁定实例的情况下完成的(使用java.util.concurrent.atomic变量)。如果要在队列为空时进行阻塞,则无需执行此操作,因为当队列为空时,poll()只会返回null,而poll()是原子的。检查poll()是否返回null。如果是这样,请等待(),然后重试。无需锁定。

最后:

老实说,我只会使用linkedBlockingQueue。对于您的应用程序来说,它仍然是多余的,但是很有可能会正常工作。如果性能不够(PROFILE!),则可以随时尝试其他方法,这意味着您不必处理任何同步的东西:

BlockingQueue<YourObject> queue = new linkedBlockingQueue<YourObject>();queue.put(myObject); // Blocks until queue isn't full.YourObject myObject = queue.take(); // Blocks until queue isn't empty.

其他一切都一样。放置 可能 不会阻塞,因为您不太可能将20亿个对象放入队列。



转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/379427.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号