监控队列- ConcurrentLinkedQueue？

文章/答案/技术大牛

发布

1回答

java、design-patterns、data-structures、collections、monitor

我想实现一个监控队列，两个不相关的线程可以共享这个队列。在这种情况下，只使用ConcurrentLinkedQueue就足够了吗?或者我应该以不同的方式使用它？我想实现活动对象设计模式，有一个ActivationQueue --它是一个普通的Java队列，它必须作为一个监视器对象来实现，因为除了队列之外，还有其他的模式组件。

浏览 11提问于2017-01-12得票数 2

回答已采纳

1回答

只有一个使用者和一个生产者来实现并发队列的绝对最快的方法是什么？

java、multithreading、optimization、concurrency、real-time

我想到了java.util.concurrent.ConcurrentLinkedQueue，但是对于这种双线程场景来说，它真的是最优的吗？我正在寻找最小的延迟可能在双方(生产者和消费者)。如果队列为空，则可以立即返回null，如果队列已满，则可以立即放弃所提供的条目。 ConcurrentLinkedQueue是否使用超快光锁(AtomicBoolean)？有没有人对ConcurrentLinkedQueue进行基准测试，或者知道最快的最终方法？附加细节:我认为队列应该是一个公平的<e

浏览 2提问于2012-04-04得票数 3

回答已采纳

1回答

Java ConcurrentLinkedQueue而不是List？

java、list、concurrency、thread-safety、queue

我有一个工作线程，它应该在ArrayList<ConcurrentLinkedQueue>上迭代。其他线程可以添加和删除对象(队列)。但是ArrayList并不是线程安全的。用ConcurrentLinkedQueue<ConcurrentLinkedQueue>代替ArrayList<ConcurrentLinkedQueue>好吗？

浏览 2提问于2016-04-13得票数 0

回答已采纳

2回答

以原子方式将第一个元素添加到ConcurrentLinkedQueue

java、multithreading、concurrency、lock-free

我想以原子的方式使用：几个并发线程将事件推送到队列中，其他线程将处理这些事件。队列没有绑定，我不想让任何线程等待或被锁定。然而，读取部分可能会注意到队列变空了。因此，将第一个新事件推入空队列的写入器必须意识到这一点，并且应该重启读取器(即，通过向ExecutorService提交新的Runnable )来处理队列。不幸的是，ConcurrentLinkedQueue的方法总是返回true。在添加事件之前或之后询问队列isEmpty()是没有帮助的，因为它不是原子的。我

浏览 3提问于2012-07-26得票数 3

回答已采纳

1回答

具有唯一元素的Java线程安全并发队列

java、concurrency、queue、thread-safety

我需要一个数据结构，应该是一个并发和唯一的队列。ConcurrentLinkedQueue可以解决我的问题，但我需要在队列中添加唯一的元素(先进先出)。为了实现这一点，我必须同时使用Set和ConcurrentLinkedQueue吗？

浏览 6提问于2021-02-24得票数 0

2回答

使用ConcurrentLinkedQueue的ThreadPoolExecutor

java、threadpoolexecutor

是否可以将名为ConcurrentLinkedQueue的非阻塞队列传递给ThreadPoolExecutor而不是LinkedBlockingQueue(或任何其他阻塞队列)？

浏览 2提问于2015-01-07得票数 0

1回答

在安卓活动中共享ConcurrentLinkedQueue

java、android、queue、java.util.concurrent、ioio

我正在开发一个需要在多个活动中共享4个byte[]队列的应用程序。我使用ConcurrentLinkedQueue是因为我希望它们是非阻塞的，因为它们将与IOIO上的两个UART通信。似乎我只能将数据放在初始化队列的同一个方法中，并且当控制传递给另一个方法时，大小为0。IOIO服务循环程序将读取输出队列并将字节发送到IOIO，并从IOIO读取字节并将其放入输入队列中。其他活动将把数据放入输出队列，并从输入队列中删除数据。static Queue<byte[]>

浏览 9提问于2016-10-07得票数 0

1回答

java中ConcurrentLinkedQueue<Double>的计算平均值

java、java-8

下面定义了一个并发链接队列，如何使用流获取java 8中所有元素的平均值？ConcurrentLinkedQueue<Double> cpu = new ConcurrentLinkedQueue<Double>(); 谢谢

浏览 0提问于2014-10-16得票数 1

回答已采纳

3回答

队列的线程安全映射

java、multithreading、queue、concurrenthashmap

我想实现一个线程安全的队列映射。 map.get(key).add(value);

浏览 1提问于2014-10-21得票数 1

回答已采纳

1回答

维护ConcurrentLinkedQueue中的位置

java、queue

我有一个包含这些对象的ConcurrentLinkedQueue，我不想从队列中删除对象，但我需要知道我在队列中的位置。我有一个解决方案，但出于某种原因，我想一定有更好的方法。private static final ConcurrentLinkedQueue<InetSocketAddress> allSocketAddrs = new ConcurrentLinkedQueue

浏览 10提问于2018-02-07得票数 0

4回答

java.util.ConcurrentLinkedQueue

java、tomcat、servlets、concurrency、queue

我想使用java.util.ConcurrentLinkedQueue作为Servlet的非持久队列。下面是这个类的javadoc的格式回复信息。一个基于链接节点的无界线程安全队列。当多个线程共享对一个公共集合的访问时，ConcurrentLinkedQueue是一个合适的选择。此队列不允许使用null元素。现在假设我在servlet上有1000个并发请求，每个线程都需要在ConcurrentLinkedQueue中加入一个对象。从描述中，我应该得出结论，它在处理负载时不会有问题吗？

浏览 47提问于2009-01-12得票数 17

回答已采纳

2回答

从java中的另一个类访问静态变量

java、class、static、public

在我的多线程服务器中，我有一个作为链表实现的队列。我想从另一个类访问这个队列。这两个类都在同一个包中。我尝试将这个队列设为public static，并通过getter访问它，但是没有成功，谁能告诉我确切的问题是什么？这是我的代码:队列声明： } publ

浏览 1提问于2012-04-23得票数 5

2回答

在应用程序中存储ip地址的最佳方法是什么？

java、spring、jsf-2

我正在考虑使用ConcurrentMap<String, ConcurrentLinkedQueue<Long>>在队列(ConcurrentLinkedQueue<Long>)中存储ip地址(String该队列将由Quartz以3分钟的间隔进行清理(将删除超过3分钟的milis)。为了检查是否显示验证码，我将检查队列大小是否大于3。这是正确的方法吗？你还有更好的主意吗？

浏览 3提问于2012-07-27得票数 4

回答已采纳

1回答

当我们有ConcurrentLinkedQueue时，为什么要使用LinkedBlockingQueue？

java、multithreading、concurrency

当我有ConcurrentLinkedQueue时，我为什么要使用LinkedBlockingQueue？我知道ConcurrentLinkedQueue是非阻塞的，但是LinkedBlockingQueue可以作为ConcurrentLinkedQueue工作。如果队列为空，则poll()方法不会等待。LinkedBlockingQueue也是无限的。所以我可以用这个。到目前为止，我发现的不同之处在于，ConcurrentLinkedQueue使用的是带有比较和交换的硬件级同步机制，而LinkedBlo

浏览 3提问于2018-04-15得票数 10

1回答

Websockets和线程化服务器端端点

java、multithreading、websocket、endpoint

这里有点“菜鸟”的问题。正如我所看到的，唯一可以接收/发送消息的是端点。如果我让它实现Runnable并每隔0.5秒暂停一次，那么在暂停时间内它不会接受消息。如果我为此定义了一个不同的类，我不知道如何在端点中启动它，并为它们提供一种通

浏览 3提问于2015-05-09得票数 0

1回答

如何用csv-spring读取队列而不是arrayList？

java、spring、list、csv、queue

For线程最好使用队列，那么，如何将此方法转换为返回队列而不是ArrayList呢？

浏览 11提问于2019-12-11得票数 0

1回答

将队列转换为长数组？

java、arrays、list、queue

private final ConcurrentLinkedQueue<Long> holder = new ConcurrentLinkedQueue<>(); 我使用ConcurrentLinkedQueue是因为我将以毫秒为单位的延迟从多线程应用程序插入到上面的holder队列中，因此我希望线程安全。现在，我的问题是如何将holder队列转换为long[]长数组，以便将其传递给下面的方法？有什么办法吗？

浏览 0提问于2016-12-14得票数 1

回答已采纳

1回答

使用ConcurrentLinkedQueue导致错误

java、multithreading、lambda、syntax-error

我在使用ConcurrentLinkedQueue时出现了以下错误 ConcurrentLinkedQueue<Double> concurrentLinkedQueue= new ConcurrentLinkedQueue<Doubl

浏览 1提问于2015-12-23得票数 1

回答已采纳

1回答

条件延迟处理

java、multithreading、caching、data-structures、threadpool

我在glassfish下创建了一个新的线程池和一个新的关联侦听器。线程池的最大容量为100个线程。我有一个预定的任务每晚运行，这应该会触发来自远程客户端的HTTP请求。注意，计划的作业是，而不是客户端。但是，它会触发远程HTTP客户端来发出HTTP请求。请求的数量可以超过100个。即使请求数超过100，计划作业也应以不间断的方式运行。下面是psuedo代码 { { con

浏览 3提问于2015-06-15得票数 2

2回答

Java:如果多个线程试图访问从LinkedList而不是ConcurrentLinkedQueue实现的队列，会发生什么？

java、multithreading、concurrency

如果多个线程试图访问从LinkedList而不是ConcurrentLinkedQueue实现的队列，会发生什么情况假设每个线程只使用add()和poll()，没有其他函数调用，这两个操作是原子的吗？如果它们是原子的，那么使用ConcurrentLinkedQueue而不是常规的LinkedList实现有什么好处吗？

浏览 0提问于2015-11-26得票数 1

点击加载更多