在没有O_NONBLOCK的情况下创建消息队列时，如果队列为空，则mq_receive()调用阻塞。当一条新消息被发送到队列时，哪些等待的mq_receive()调用实际上解除阻塞？QNX文档明确提到FIFO顺序：
所有POSIX IPC实现都是这样吗？Linux实现是做什么的
浏览 0提问于2019-12-02得票数 1
回答已采纳
1回答
我正在设计一个单进程多线程嵌入式Linux应用程序.该设计包括客户机-服务器子系统，其中工作线程接收POSIX消息队列上其他线程发布的消息。
我需要队列显示非阻塞发送和阻塞接收语义。我可以想出几种实现上述功能的方法：-创建两个单独的消息队列描述，用于为了发送和接收访问队列，即两次调用mq_open。随后将设置用于通过队列发送的描述的O_NONBLOCK标志。指定阻塞行为并使用mq_
浏览 12提问于2020-02-27得票数 3
回答已采纳
最近，我正在学习Linux上的进程通信。我编写了一个C程序来做以下事情：
但是，当我编译相同的代码并试图在macOS(Sierra10.12.3)上运行时，结果与Ubuntu上
浏览 2提问于2017-04-28得票数 1
回答已采纳
1回答
当我试图减少POSIX消息队列中的消息数量时，它保持最大数量为10。是否可以减少或增加POSIX消息队列中的消息数量？send.c#include <mqueue.h>
#include
浏览 6提问于2013-03-31得票数 2
回答已采纳
3回答
在GNU OS中，只有当另一个进程同时读取相同的数据(来自同一管道)时，进程才能将数据写入管道。
是否有类似于让第一个进程写入和缓冲数据直到第二个进程读取数据的管道？
浏览 0提问于2014-10-26得票数 12
2回答
gcc 4.7.2我正在寻找一个轻量级的消息队列(IPC)，这是跨平台(linux，windows)。基本上，我有一个事件循环，我将阻塞(单独的线程)，直到我从消息队列(msgrcv)获得消息。然后处理该事件。消息将来自我创建的另一个共享库，我将在事件循环中从该共享库监视事件。
我只希望能够将消息发送到消息</e
浏览 18提问于2012-12-26得票数 5
所以我的问题是，为什么linux极客没有在msg队列id上实现轮询/选择？这会导致严重的问题吗？
我需要实现这样的机制。我该怎么做呢？
浏览 2提问于2012-04-06得票数 4
1回答
我想知道如何在linux操作系统上配置posix队列。我知道如何在sysctl.conf和代码中编辑还有其他方法可以配置每个队列的消息数量和队列数量吗？
浏览 1提问于2014-03-14得票数 1
回答已采纳
1回答
简短摘要：
我希望将消息发送到队列，并使多个线程处理这些消息。应用程序应该只是异步地将消息发送到Gateway，但在队列已满时应该会被阻塞。另外，我还想将消息传递到多线程队列。我的问题是，我的队列永远不会阻塞并接收比实际大小更大的消息。
浏览 4提问于2017-10-27得票数 2
回答已采纳
我们有一个在兔队列中发送消息的服务，配置如下： spring: stream: output:
destination，我们注意到到消息队列的连接被阻塞了：Blocked queue 当RabbitMQ服务器使用超过40%的可用内存时，似乎出现了阻塞，它会发出内存警报，并阻止所有发布消息的连接。我们的问题是，在这种特殊情况下，我们丢失了队列中发送的消息
浏览 43提问于2020-12-17得票数 0
1回答
问题
与使用在互斥锁中包装日志记录函数相比，使用队列有什么优势？似乎大多数(如果不是所有的)建议都是针对队列的，但我还没有看到任何真正的解释。
浏览 0提问于2014-01-29得票数 4
让我困惑的是，我看不出使用共享数据和消息队列之间的区别。我现在正在做一个windows上的非gui项目，所以让我们使用windows的消息队列。并以传统的生产者-消费者问题为例。使用消息队列，生产者可以简单地PostThreadMessage而不阻塞。这就是异步消息的优势。但我认为在两个线程之间一定存在一些锁来保护消息队列，否则数据肯定会损坏。我不知道我的猜测是否正确，但如果它是真的，优势似乎不再存在，因为这两种方法
浏览 3提问于2011-08-19得票数 6
回答已采纳
1回答
我正在尝试理解是如何避免阻塞的场景1:在阶段2中，协调器向所有队列发送preCommit消息，并且除了队列A之外的所有队列都收到了ack。网络问题阻止队列A接收协调器的preCommit消息。队列A等待preCommit消息超时并选择中止。然后协调人和队列A都崩溃了。
场景2:协议到达阶段3。协调器向队列A发送doCommit消息。但是在它可以发送更多do
浏览 41提问于2014-01-29得票数 24
回答已采纳
3回答
Looper的循环方法在ActivityThread的main方法中调用，并启动一个无限for loop，它在消息队列上迭代。当队列中没有更多消息时，它将调用nativePollOnce方法，该方法等待下一条消息。1.如果等待下一条消息，那么主线程将被阻塞，那么它如何才能使更多的消息队列排队。2.如果它不被阻塞，那么它将消耗CPU周期，而其他人将没有机会在队列中添加消息</
浏览 9提问于2020-05-21得票数 0
我面临一个关于消息队列的问题：
最后，我将select()和mq_timereceive与NO_WAIT结合起来。超时之后，我将得到带有mq_timereceive()的消息队列，当然绝对时间= 0；
但是我的问题是:如果系统中有许多线程在等待相同的消息<
浏览 2提问于2016-04-24得票数 2
1回答
我有4-5个工作线程处理大型消息队列。我还有另外一段代码，它使用2-3个工人来运行。我想在处理大型消息队列时阻止所有其他工作进程。编辑：
队列进程工作进程从未终止。当没有消息时，它们阻塞在队列上。这些工作线程由executor线程pool.If管理，我使用读写锁，其中一个工作线程也会被阻塞。此外，如果使用循环屏障，那么我必须终止线程，以便重新释放阻塞的第二个进程。因为工作线程是由线程池
浏览 0提问于2013-04-09得票数 1
1回答
Thread message queue blocking; consider raising the thread_queue_size option (current value: 8) 以上是我收到的消息
浏览 205提问于2020-08-25得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
