设置队列大小的限制

文章/答案/技术大牛

发布

1回答

queue.queue()设置大小的最佳实践？

python、multithreading、queue

所以我有Queue.Queue()1)限制队列大小与不设置队列大小是否有好处？ 2)不封顶大小，真的没有大小限制吗？我注意到，当队列大小固定时，死锁似乎更容易发生

浏览 2提问于2016-09-25得票数 0

2回答

erlang

如何设置一个队列来保存N个值。当达到N时，删除最后一项并将一个值添加到队列的前面。我还想在添加新项时计算队列中的值。例如，将队列中的所有值相加。

浏览 4提问于2010-11-30得票数 1

回答已采纳

1回答

Azure服务总线的最大队列大小

azure、azureservicebus、azure-servicebus-queues

高级Azure服务总线最大队列大小为80 is。什么情况下，您设置的队列不超过最大允许的限制。

浏览 1提问于2019-07-31得票数 0

回答已采纳

1回答

MSMQ专用队列大小限制

windows-7、c#-4.0、msmq、netmsmqbinding

我正在尝试将消息放入在本地计算机上定义的专用队列中，但队列大小不能超过8MB。每次达到该大小后，我都会得到一个异常。指定队列的大小设置为10 GB。我运行的是Windows 7专业版。有没有因为这一点而受到限制？

浏览 0提问于2010-04-29得票数 2

回答已采纳

2回答

How字节属性应该如何工作？

jms、tibco、tibco-ems

根据这怎么可能？谢谢!

浏览 0提问于2013-12-04得票数 0

1回答

如果队列达到限制，python将等待RabbitMQ发布服务器

python、rabbitmq、pika

我有一个场景，一个python脚本，它将发布150 k消息，每个消息的大小最大为10 at。然后，我将队列限制设置为最多5000条消息。然后，发布者将将消息发布到队列中，直到达到限制5000消息为止。我想问的是，如果队列已满，发布者可以等待发布消息吗？而不丢弃信息。将再次检查队列是否可用，然后发布者将发布数据。

浏览 0提问于2018-06-05得票数 0

1回答

RabbitMQ -有没有办法限制队列中的消息数量？

rabbitmq、message-queue、amqp

有没有办法限制一个队列在RabbitMQ中可以容纳的最大消息数？例如，如果此数字设置为10，而当前大小为10，则在将新消息推送到队列(FIFO)时，最旧的消息将被丢弃。

浏览 14提问于2017-06-29得票数 3

回答已采纳

3回答

服务总线资源管理器

service

我们的项目是在Windows2012 R2服务器上运行( on )来进行消息处理。当将消息发送到超过大小限制(例如10 mb )的服务总线主题时，服务总线显示处理错误-抛出套接字超时异常。对于如何处理这一问题的任何建议方法，将不胜感激。此外，是否有一种方法可以通过Powershell cmds或service增加服务总线超时配置或服务总线主题上的消息大小限制设置。

浏览 1提问于2019-04-03得票数 1

1回答

ActiveMQ消息队列在200多万条消息后变慢

activemq

我有一个名为amq570queue的消息队列，在积累了两百万条消息后，它开始变慢。我需要调整哪些代理设置来解决此问题？我临时将它移动到一个新的消息队列中(在同一个代理中)，它工作得很好。我最初认为kahadb已经达到了它的大小限制，这就是为什么它变慢了。有没有办法限制出列消息的大小？提前感谢您的任何投入。向您致敬，沃尔特

浏览 2提问于2013-10-23得票数 0

1回答

限制字节的tc替代方案？

linux、networking、qos、trafficshaping

是否有一种替代tc(随机公平排队)允许根据数据包大小(总字节)而不是分组计数来配置限制？其原因是，假设数据包大小为50字节，例如，一个htb类(rate=1000kbit)可以将每10 is的25个数据包排在队列中，但数据包大小为1500个字节，每10ms只有0.83个数据包。如果我将tc限制设置为25个数据包，那么在最坏的情况下，一个完整的队列将需要300 in才能清空。这是在Linux3

浏览 5提问于2014-08-17得票数 0

回答已采纳

1回答

Python3日志记录: QueueListener + SocketHandler，第一次清除队列非常慢

python、performance、python-3.x、logging

在我的Python 3代码中，我设置了这样一个记录器： def dequeue(self,(接收日志消息的服务器已经启动并运行)，队列将很快被填满。它只从队列中删除(即发送)2到3条消息，因为每添加到队列中的消息就有20-30条。如果它确实能够清除队列并在此时发送基本上是几个GBs的LogRecords，那么它将再次加快速度

浏览 3提问于2017-07-17得票数 3

1回答

具有内存大小限制的Java队列

java、memory-management、collections、queue

我一直在尝试寻找具有特殊大小限制的Java队列实现。与通常限制队列中对象数量的size参数不同，我需要限制队列的最大内存使用量(以字节为单位)。队列将用于容纳大小非常不同的对象，有些很大，有些很小。也就是说，队列将只保存少量的大对象和大量的小对象。另一种可能是在insert方法中使用size参数的</

浏览 1提问于2015-04-06得票数 1

1回答

我有一些代码，我正在考虑放入Azure函数，我有一个关于内存限制和函数如何扩展的问题/关注。我的理解是，最多可以有10个实例，其中有x个并发执行，但是如果最大容量只允许我在没有超时的情况下运行一个执行，这是否意味着我需要手动将最大并发执行设置为1，并且它将自动扩展到最多10个实例，这意味着我一次只能执行它是一个文件操作函数，因此我可以根据输入文件大小合理准确地猜测将使用多少内存，因此，如果我重组后端以根据输入大小填充各种队列，我可以为高端内容

浏览 5提问于2017-06-17得票数 1

回答已采纳

1回答

如何对卡夫卡制片施加反压力？

apache-kafka、rate-limiting、backpressure

可以通过限制队列大小来提供帮助，从而为队列中已经存在的作业保持较高的吞吐量和良好的响应时间。卡夫卡是怎么做到的？这能通过在卡夫卡生产商和经纪人之间保持速率限制器(TokenBucket)来实现吗?在这种情况下，当前桶的大小和加注率可以用消费率的值动态地设定？就像生产者中的rest一样，从使用者那里接收消

浏览 9提问于2022-09-16得票数 0

4回答

如何确定USRQ中的最大消息数*

ibm-midrange

它需要创建最大可能大小的*USRQ。根据文档，*USRQ的最大大小是2Gb。创建队列需要指定最大消息大小、队列中消息的初始数量、队列扩展的大小(以消息为单位)和最大展开操作数。消息大小为1024字节。最初的数字是128条消息。队列将扩展128条消息。估计最大可能的消息数- 2Gb / 128字节。然后，我们减去消息<e

浏览 12提问于2022-05-10得票数 2

回答已采纳

1回答

AWS处理S3文件不够快

amazon-web-services、amazon-s3、aws-lambda、amazon-sqs

我的要求是处理在S3中创建的文件，并将文件的内容流到SQS队列中，该队列将由其他进程使用。当在S3桶中创建新文件时，通知将发布到SQS，这将触发lambda和用编写的lambda处理该文件，并将内容发布到SQS。文件的最大大小是100 MB，所以它可能有300 K的消息，但它正在处理非常缓慢。我不知道问题出在哪里，我已经将lambda内存限制设置为10 GB，运行时设置为15分钟。

浏览 2提问于2021-12-23得票数 -2

2回答

MSMQ队列大小有限制吗？

size、queue、limit、msmq

我知道消息的大小限制(4MB)，但是队列大小有限制吗？也许是最佳实践限制？

浏览 0提问于2011-12-06得票数 9

回答已采纳

1回答

log4j 1.2 -异步记录器内存使用限制设置

java、memory-management、log4j

我想知道是否有一种方法来限制异步记录器将使用的内存量。有一个缓冲区大小可以限制日志元素在写入磁盘之前的数量，如下所示： <appender name="async" class="org.apache.log4j.AsyncAppender">似乎没有任何方法来限制log4j将使用的内存量。默认的缓冲区大小是128 LoggingEvents，但理论上每个LoggingEvent

浏览 0提问于2018-02-08得票数 1

回答已采纳

1回答

ActiveMQ -在不影响生产者的情况下限制队列中挂起消息的数量

activemq

ActiveMQ 5.15.4我尝试过的事情：</policyEntry> 这正确地限制了队列大小，但正如描述的所描述的那样，它

浏览 0提问于2018-09-08得票数 0

2回答

并发标记扫描集合发生频率不高

java、garbage-collection、concurrent-mark-sweep

我的应用程序在一个服务器上正确运行，服务器上有16个处理器和64 GB的Ram。我有多个进程，我试图将我的进程的最大堆限制在8 G字节。我的问题是，我有某种形式的生产者-消费者模式，我必须限制生产速度，否则我将耗尽内存，因为为老一代垃圾收集发生太少。通过JVisualVM，我可以看到90%的内存是由CMS老一代完成的，我怎样才能强迫并发的Mark扫描更频繁地运行呢？@PeterLawrey注释非常相

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

回答已采纳

点击加载更多

queue.queue()设置大小的最佳实践？