1回答
我正在设计一个单进程多线程嵌入式Linux应用程序.该设计包括客户机-服务器子系统，其中工作线程接收POSIX消息队列上其他线程发布的消息。
我需要队列显示非阻塞发送和阻塞接收语义。我可以想出几种实现上述功能的方法：-创建两个单独的消息队列描述，用于为了发送和接收访问队列，即两次调用mq_open。随后将设置用于通过队列发送的描述的O_NONBLOCK标志。
指定阻塞行为并使用mq_timedsend代替mq_send
指定阻塞行为并在mq_getattr之前调用mq_send以避免在发送时阻塞
第一种解决方案可能是首选的解决方案，但要使其工作，必须保证每次对mq_open的调
浏览 12提问于2020-02-27得票数 3
回答已采纳
2回答
在iTron中，有较轻版本的消息队列称为数据队列。它们非常容易用于快速消息传输。Linux中是否存在任何等价的同步原语？
数据队列的定义:它是一个单词消息()的队列。
浏览 2提问于2009-04-10得票数 1
回答已采纳
在嵌入式Linux环境、System消息队列或Posix消息队列中应该使用什么？在项目中普遍使用的是什么？
浏览 5提问于2014-01-23得票数 4
回答已采纳
我面临一个关于消息队列的问题：
我使用mq_timedreceive()在abs_timeout时获取消息队列。但这一功能受系统时间(CLOCK_REALTIME)的影响。我的意思是，当系统时间改变时，abs_timeout (绝对时间)不再正确。
为了解决这个问题，我意识到它应该改为CLOCK_MONOTOIC时钟。但是在linux中，没有办法(我搜索并发现QNX支持这种机制)。
最后，我将select()和mq_timereceive与NO_WAIT结合起来。+ select()：使用相对时间，因此不受系统时间变化的影响。超时之后，我将得到带有mq_timereceive()的
浏览 2提问于2016-04-24得票数 2
有谁知道GLib的GAsyncQueue与POSIX message_queue用于线程间通信的相对性能吗？我将有许多小消息(包括一种方式和请求-响应类型)，将在Linux之上用C实现(目前；稍后可能会移植到Windows )。我在决定用哪一种。
我发现，在可移植性方面，使用GLib更好，但是POSIX的优点是能够对它们进行选择或投票。
然而，我没有发现任何关于谁的表现更好的信息。
浏览 1提问于2012-02-10得票数 13
1回答
我正在研究一个小型网络系统原型，在它的最低层，有一个软件“父”进程，与5个软件“子”进程来回通信。
我正在使用ZeroMQ在进程之间进行通信。
我的问题是多线程处理与单线程处理的问题。
在这种系统中，父线程中处理往来于子进程的消息的单个线程会比5个线程(每个进程一个线程)更有效吗？
对于单线程，我担心的是，当父进程处理一条消息时，消息将开始堆积。
对于多线程，如果扩展这个系统架构，我会关注上下文切换和性能问题。想想50位家长，每件5条，所以至少250条。
线程被写入，没有锁、关键部分、共享内存等等。
我使用Linux和C++。
浏览 2提问于2018-09-07得票数 0
回答已采纳
在没有O_NONBLOCK的情况下创建消息队列时，如果队列为空，则mq_receive()调用阻塞。当一条新消息被发送到队列时，哪些等待的mq_receive()调用实际上解除阻塞？
QNX文档明确提到FIFO顺序：
如果多个mq_receive()调用在单个队列上被阻塞，那么它们将在消息到达时按FIFO顺序解除阻塞。
所有POSIX IPC实现都是这样吗？Linux实现是做什么的？该手册相当不具体：
如果队列为空，则默认情况下，mq_receive()会阻塞，直到消息可用，或者呼叫被信号处理程序中断。。
浏览 0提问于2019-12-02得票数 1
回答已采纳
5回答
我正在设计一个websocket服务器，它接收消息并将其保存到嵌入式数据库中。用于阅读我正在使用的消息。为了将消息保存到嵌入式数据库，我在前面看到了几个选项：
在同一线程上接收到消息后，立即同步保存它们。
将消息异步保存在单独的线程上。
我很确定第二个答案是我想要的。但是，我不知道如何将消息从套接字线程传递到IO线程。我认为有以下几种选择：
每个线程使用一个io服务，并使用在线程之间进行通信。在这里，我必须担心锁争用。我应该吗？
使用Linux域套接字在线程之间传递消息。据我所知，没有锁定争用。在这里，我可能可以使用BOOST_ASIO_DISABLE_THREADS宏
浏览 6提问于2016-05-24得票数 6
我在Linux上使用Posix消息队列。基本上，我有多个线程通过调用mq_timedreceive从同一队列接收消息。
如果多个线程同时运行并且队列不为空，是否可以保证消息不会被多次接收(即消息不会被传递到多个线程)？
可以肯定的是，我可以将接收与互斥同步，但如果可能的话，我希望避免这个锁。我阅读了所有的手册页(man mq_overview(3))，但没有找到任何明确的内容。
提前谢谢。
浏览 4提问于2012-03-02得票数 4
回答已采纳
我有一个p线程应用程序，我目前使用常规linux管道来通信，并向不同的线程发送消息。它的工作很好，并没有真的坏，但我有一种唠叨的感觉，它可以改进。
如果我想设计最小的延迟，那么最快的方法是什么呢？使用条件变量会比管道更快吗？
我需要传递少量的数据，作为一个带几个参数的独立的optcode。线程条件变量允许我在线程之间传递数据吗？
谢谢,
-Andres
浏览 0提问于2012-12-10得票数 1
回答已采纳
5回答
我正在研究一个用于嵌入式Linux进程间通信的消息队列。我想知道为什么我不使用Linux提供的消息队列，如下所示：
msgctl，msgget msgrcv，msgsnd。
而不是创建共享内存，并与信号量同步？
在商业嵌入式产品上直接使用这组函数有什么缺点？
浏览 13提问于2012-03-05得票数 14
回答已采纳
我们有一个独立的java应用程序在Debian机器上做一些后台处理。它必须处理的作业是通过RabbitMQ消息发送的。
当java应用程序需要升级时，我们需要停止它(终止它)。但我们必须确保当前没有消费者正在处理消息。根据您的经验，实现这一目标的最佳方法是什么？
我们试图向消费者发送“关闭”消息，但似乎无法关闭队列或通道？！它冻结了应用程序！或者有没有其他的解决方案，例如，我们可以自动关闭应用程序，而不需要在linux中执行kill命令？
谢谢分享你的经验。
问候
浏览 3提问于2011-07-15得票数 9
2回答
对于串行IO来说，我在尝试实现一个相当简单的例程时，会遇到一些心理障碍。
情况是，我们有一个嵌入式linux (想想Pi / Beagle)，它使用与UART上的另一个设备进行通信。
问题是我们有两个冲突的要求：
在传输方向上，我们希望阻止 msgrcv()函数，直到消息到达才发送。
在接收方向上，我们需要等待/阻止传入消息(该消息可以具有规范模式操作的终止字符)。
Tx和Rx是异步的，彼此之间没有关系--两者都可能在任何时候发生。
轮询会带来痛苦，因为它会在CPU周期和响应延迟中引入开销。
一种方法是将其分成两个线程，一个处理Tx和msgrcv()上的阻塞，另一个在Rx和UART read(
浏览 16提问于2014-01-02得票数 3
回答已采纳
我正试图解决我的p线程Linux代码中的多线程套接字使用问题，考虑到我的需求，我认为它可能是无法解决的。你能告诉我你是否同意吗？
问题是：
I有多个线程写入单个SOCK_STREAM (TCP)套接字(设置为非阻塞IO)。每个线程都试图一次编写一个“消息”，来自不同线程的消息数据绝不能交织。I为send()准备在少数情况下返回EWOULDBLOCK/EAGAIN (在这种情况下，我只是将消息的写入推迟到使用互斥保护队列结构的异步线程)无法在这些前景写入线程上获得互斥(除了EWOULDBLOCK/EAGAIN )，因为隐含的缓存闪存给我一个不可接受的CPU影响(这也意味着不能使用其他同步对象来解
浏览 4提问于2019-10-14得票数 0
3回答
我需要写一种代理服务器，我的设计有点像这样:1.Socket服务器(使用Windows事件选择模型)。程序有一个监听线程监听网络事件。
客户端列表(当前按socketid_list编制索引)。3.套接字服务器接受新的连接，然后为每个客户端创建新的线程。新线程创建到终端目标服务器的套接字连接(需要持久连接)。
我已经编写了套接字服务器，它工作得很好。我的问题是，当新消息从客户端传入时，我如何将此消息传递到相关线程(以便消息可以发送到目标服务器)。
在我的服务器中，我从客户端消息中获取最终目标服务器的地址。我可以从客户端套接字列表中查找客户端套接字。但是我该如何将消息发送到正确的线程呢？
到目前为
浏览 0提问于2011-09-01得票数 2
回答已采纳
2回答
我正在windows上调试GUI应用程序，我想找出谁是一些消息的发送者。在linux上，我可以在中运行app，并在调用堆栈中找到发送者。在windows中有没有等同的模式？
浏览 0提问于2011-05-31得票数 0
回答已采纳
我知道当发送一条消息时，它具有hwnd值，以便系统知道哪个窗口负责处理该消息。当hwnd为空时，则意味着这是线程消息。那么用来处理该消息的过程函数是什么呢？
浏览 2提问于2012-04-27得票数 0
回答已采纳
3回答
首先，我已经有一段时间没有使用任何类型的互斥或信号量了，所以请轻松一点。
我实现了一个通用日志类，它现在只接收来自其他类的消息，并在消息前面加上日期/时间和调试级别，然后将消息打印到stdout。
我希望实现某种队列或缓冲区，它将保存发送到日志类的许多消息，然后将它们写到文件中。
我遇到的问题是我无法决定如何/在哪里保护队列。
下面是我到目前为止想出的一些伪代码：
logMessage(char *msg, int debugLevel){
formattedMsg = formatMsg(msg, debugLevel) //formats the msg to include da
浏览 7提问于2013-11-05得票数 2
回答已采纳
一个进程中有几个进程和一些线程。所有的过程都需要相互交流。一个进程中的线程需要与进程(主线程)对话。我想知道这个设计是否有效：
每个进程都有一个msg队列(使用msgget()、msgsnd、msgrcv() )，这样它们就可以通过linux相互交谈。
每个线程都有一个msg队列(也使用msgget、msgsnd、msgrcv )，以便它可以与主线程和其他线程对话。因此，线程所在的进程将有进程队列和线程队列，有问题吗？
我担心第2项，因为我了解到msgget、msgsnd、msgrcv是用于进程间通信的。我读过关于这些功能的手册。似乎没有提到这些函数是否支持线程。另外，你能给我
浏览 3提问于2012-03-09得票数 2
回答已采纳
1回答
我在Azure存储中有一个队列，名为“messages”。每1小时，某个服务推送到这个队列，需要更新数据的消息数量。但是，在某些情况下，我也从另一个地方推送到这个队列消息，我希望这个消息被立即进行，并且我不能为这个消息设置优先级。
解决这个问题的最好办法是什么？我是否可以使用两个不同的队列(“消息”和“消息-优先级”)，或者这是一种糟糕的方法？
浏览 2提问于2014-01-19得票数 11
回答已采纳
2回答
等待和通知看起来像是在线程之间传递的消息，如果这是真的，那么必须有队列来缓冲这些消息。如果是这样的话，那么必须有原子操作来向队列添加消息和从队列中删除消息，还必须为侦听这些消息的每个Java线程提供一个帮助线程？
很高兴听到你的想法。
浏览 0提问于2013-10-08得票数 10
4回答
我必须为一个问题设计多线程模块。问题是，我有一个队列，有一个线程将消息放入消息队列，有两个线程A和B，线程A处理偶数消息(0，2，4.)而线程B处理奇数消息(1，3，5..)。我想出了两个解决方案，第一个是使用两个事件(例如X和Y)事件X用于线程A，Y用于线程B。我检查消息是否处于均匀位置，我为线程A设置事件X，否则为线程B设置事件Y。第二种解决方案是让每个线程有两个独立的任务。线程将偶数位置消息放到线程A的队列中，将奇数消息放到线程B的队列中，这样线程A和线程B就可以异步工作。我说的对吗，或者还有其他优雅的解决方案吗？
谢谢。
浏览 1提问于2010-02-07得票数 1
回答已采纳
1回答
我有一个嵌入式Linux平台( Beagleboard，运行Angstrom )，它连接了两个设备：
通过USB连接的激光测距仪(Hokuyo UTM 30)
通过SPI连接的自定义外部板
我们有一个编写的Linux内核模块，它负责SPI数据传输。它有一个IRQ处理程序，其中调用了，这反过来导致调用一个异步回调方法。
我的C++应用程序由三个线程组成：
用于数据处理的主线程
激光轮询线程
SPI轮询线程
我正在经历一些问题，这些问题似乎是由上面描述的模块的交互方式引起的。
当我关闭USB设备(激光测距仪)时，我正确地接收到所有SPI消息(每3ms有一条消
浏览 4提问于2011-10-06得票数 8
4回答
如何判断一个线程是否有消息队列？
、、、、
有没有办法从threadId中找出一个线程是否有消息队列？
基本上，有一些windows api只有在线程具有消息queue.window时才起作用。
浏览 0提问于2009-11-24得票数 2
回答已采纳
2回答
消息总线的最佳容器
、、、、
我正在C++中设计我自己的消息总线，它将作为基于组件的游戏的后端。消息总线将具有以下特性：
经常迭代，从第一个元素开始，最后一个元素结束。
在随机地点很少移除元件
理论上无限元素数
理论上，消息类型的数量是无限的。
需要尽可能快地跑
所有元素都将包含一个指向消息处理程序的指针。
螺纹安全
我的问题是：
储存这些资料的最佳容器是什么？这并不局限于标准的C++，因此boost容器是适用的，只要容器在Windows和Linux之间是跨平台的。
浏览 1提问于2013-10-23得票数 2
回答已采纳
4回答
我有6个线程在我的应用程序中持续运行。场景是：
一个线程不断地获取消息并插入到消息队列中。其他4个线程可以看作是不断地从队列中获取消息并对其进行处理的工作者。另一个最后一个线程填充分析信息。
问题：
现在获取消息线程的休眠持续时间是100ms。工作线程数为200ms。当我运行这个应用程序时，消息获取线程正在控制并插入到队列中，从而增加了堆。工作线程没有机会处理消息并释放它们。最后它会导致内存不足。
如何管理这种情况，以便为消息获取线程和工作线程提供平等的机会。
提前感谢:)
浏览 0提问于2012-12-19得票数 1
回答已采纳
2回答
我有一堆等待消息的线程被阻塞。每条消息都有一个指向特定主题的ID。我有以下实现：
1)所有线程都在使用Monitor.Wait等待同一个锁对象。当有消息进来时，我调用Monitor.PulseAll，每个线程检查自己的ID和消息ID，如果匹配，线程继续。否则，它将再次等待同一对象。使用这种方法，每个消息到达都会导致N-1个线程唤醒，并与ID不匹配，然后返回睡眠。
2)每个线程创建一个ManualResetEvent并将其添加到字典中。字典将消息id映射到其事件。当消息到达时，它调用map[message.Id].Set()来唤醒特定的线程。
3)最后一个实现与#2非常相似，只是它使用了一个锁对
浏览 2提问于2015-09-04得票数 0
在下面的示例中，我将最大和核心池大小设置为1。但是没有处理任何消息。当我启用调试日志时，我能够看到从SQS中提取的消息，但我猜它没有被处理/删除。但是，当我将核心和最大池大小增加到2时，消息似乎会被处理。
编辑
我相信Spring可能会为接收者分配一个线程，用于从队列中读取数据，因此它无法将线程分配给正在处理消息的侦听器。当我将核心池大小增加到2时，我看到消息正在从队列中读取。当我添加另一个侦听器(对于死信队列)时，我遇到了同样的问题--2个线程不够，因为消息没有被处理。当我将核心池大小增加到3时，它开始处理消息。在本例中，我假设分配了一个线程来读取队列中的消息，每个线程分配了两个侦听器。
@
浏览 1提问于2018-04-27得票数 13
回答已采纳
我有一些关于“消息循环”的理论问题；特别是返回在不同线程中运行的消息循环中发生的操作的结果。在这种情况下，我让TCP服务器侦听传入的消息。对于每一条传入消息，服务器将对发送消息的客户端进行身份验证，可能会发生两种情况：
如果经过身份验证的客户端有附加的处理程序，则接收到的消息将被传递到处理程序的消息队列。
如果客户端没有处理程序，将创建一个新的处理程序，并与上面相同(消息将传递到它的消息队列)。
当前，处理程序是一个实现可调用接口的对象，因此它将在一个不同的线程中运行，并且它足够简单地获得操作的结果。现在，对于我的问题:每个处理程序可以处理N个消息。处理程序有一个"me
浏览 1提问于2015-02-05得票数 1
回答已采纳
我有一个客户端套接字列表，通常大小在2000左右。这些客户是动态的，他们来来往往。
我有一个由32个线程组成的固定线程池的ExecutorService来处理这些线程。此执行器服务负责解码和发送要发送给这2000客户端的消息。
我希望防止执行器服务的两个(或更多)线程同时处理同一个客户端。
一种方法可以是引入另一个簿记线程(因此我最终得到32 +1个线程)，它负责在完成与同一个客户端对应的前一条消息时调用ExecutorService.submit(mesage)。但我不确定这是否会引入瓶颈，这意味着这个新引入的簿记线程无法继续提交消息。
理想情况下，我不希望预先将线程分配给一组客户端，因为消
浏览 0提问于2018-08-14得票数 3
回答已采纳
1回答
我在Ubuntu上使用单独的线程调用pygame.event.get()很长时间了，没有任何问题。然而，MacOS抛出了一个异常'NSInternalInconsistencyException', reason: 'nextEventMatchingMask should only be called from the Main Thread!'；并且在正常执行几秒钟后，Windows报告窗口是(Not answering)的，我假设这有相同的解释，这意味着Linux与其他OSes不同的是，Linux对这种软件设计是有容忍度的。
有没有办法在单独的线程中清空事
浏览 0提问于2017-10-23得票数 5
我有一个包含多个入站通道适配器的上下文，每个适配器都有自己的轮询器(当前所有计票器都配置有固定延迟的刷新时间，但将来可能使用固定速率)。所有入站适配器都将产生的消息输出到同一个处理链。问题是，在这种情况下，投票和信息消费的行为是什么？想象一下，poller #1已经生成了1000条消息，并将它们传递给我的处理链。由于处理可能需要相当长的时间，所以轮询器#2完成其工作并可能产生消息的时间已经到来。但是请记住，我的处理链仍然在处理poller #1传递的消息。发生了什么？
在所有Poller #1消息被处理之前，poller #2根本不会运行。
Poller #2正在运行(但是如果我们只有
浏览 4提问于2016-01-27得票数 3
回答已采纳
在Linux中，msgsnd可以从用户空间发送消息。但是，如果发送的消息数量达到最大消息数，msgsnd将阻塞，是否有方法更改最大值？谢谢
浏览 0提问于2020-06-15得票数 0
5回答
我正在尝试在一个高度多线程的环境中进行异步登录，在linux上的java中，platform.what是一个合适的数据结构(无锁)，能带来低线程争用吗？我需要记录千兆级的消息。我需要以异步/无锁的方式来做这件事，这样我就不会破坏主逻辑(调用记录器apis的代码)上的性能。
浏览 1提问于2013-01-15得票数 1
Indy服务器组件似乎依赖于Windows消息，因为只有当鼠标光标移动到包含服务器组件的窗体上时，才会出现新的消息。
我在运行时使用以下代码创建了该组件：
private
{ Private declarations }
Srv: TIdUDPServer;
...
procedure TForm1.FormCreate(Sender: TObject);
begin
Srv := TIdUDPServer.Create(Self);
Srv.DefaultPort := 9009;
Srv.OnUDPRead := Self.udpServerUDPRead;
浏览 17提问于2011-10-04得票数 3
回答已采纳
1回答
我正在使用处理文件。这是我的配置
<int:channel id="startChannel">
<int:splitter input-channel="startChannel" output-channel="parseChannel" ref="splitter" method="split" />
<int:channel id="parseChannel">
<int:queue size="50"/>
</i
浏览 2提问于2017-03-26得票数 0
回答已采纳
我们有一个代表多个客户端的分布式应用程序。现在，当工作到达时，消息被放在单个队列中。消息是以FIFO顺序提取的，这在大多数情况下都工作得很好。
在某些情况下，我们将为单个客户端获取数千条消息，然后这些消息将占用队列中的前几个thousand+插槽。这意味着在处理这些消息之前，不能(或很少)为任何其他客户端执行任何工作-这会使较小的客户端处于饥饿状态。
我的想法是，在我们引用客户端列表之前，以及每次从队列中获取消息之前，我们都会查看消息，看看是哪个客户端提交了该消息。如果它是针对我们刚刚处理的同一客户端，我们将其推回，直到我们找到针对不同客户端的消息，或者迭代所有客户端，但找不到其他工作。
这是
浏览 0提问于2016-01-19得票数 1
会不会是DistributedTxMessageListenerContainer上的MaxConcurrentListereners用处不大？我的印象是一次只有一个线程可以处理队列中的消息。也许这是合乎逻辑的，因为只有在事务成功后，消息才会从队列中删除。还是我说错了？
浏览 0提问于2011-01-04得票数 0
3回答
有趣的是，这似乎是一个基本的问题，但我在C语言中找不到它的任何例子(因此，我只找到了Python、C#和C++)。
要点是:作为一个Qt程序员，当我需要在不同线程之间传输一些数据时，我会在此之间启动一个信号槽连接，并使用emit signal机制来完成工作。
但是现在我正在为嵌入式Linux开发一个C应用程序，在那里我需要做类似的工作，但是我没有Qt的机制。问题是：如何使两个或多个线程在C中以类似于Qt具有信号和插槽的方式进行通信？
我知道共享数据的方法之一是使用具有互斥保护变化的全局变量。但是即使这样，我也可能无法以异步的方式完成系统:我必须有一个循环来不断地检查变量是否已经改变。但是，如果
浏览 7提问于2014-09-16得票数 9
我使用的是Linux3.2.0，x86_64。我可以同时从多个线程中为一个套接字调用accept()吗？
浏览 0提问于2012-07-15得票数 9
回答已采纳
我想做的是让一个线程等待消息(WaitMessage)，另一个线程处理应用程序的逻辑。第一个线程会在每条消息上醒来，以某种方式将这个事件发送给另一个线程，然后再去睡觉，等等，这可能吗？
更新
考虑以下情况。我们有一个GUI线程，这个线程在长时间的计算中很忙。如果没有其他线程，则别无选择，只能不时检查新消息。否则，在长时间的计算过程中，GUI就会变得没有响应。现在，我的系统使用了这种“轮询”方法(它有一个线程，可以不时地检查消息队列)。但是，我想知道另一种解决方案是否可行:让另一个线程等待GUI的OS消息队列，这样当Windows消息到达时，这个线程就会醒来并告诉另一个线程有关消息的信息。注意，
浏览 9提问于2015-12-05得票数 0
回答已采纳
背景:我需要以异步方式向WebSocket客户端发送许多小规模的消息。消息通常是在峰值发送，所以在暂停之后，我需要快速发送5000条消息。所以问题是：
我不想在单线程中启动5000异步
我不想在串行中循环“启动异步”--“等待完成”5000次
我不想使用5000个线程，使用单个“启动异步”-“等待完成”每个线程
最好的方法是每个线程分组~20异步，所以我需要非常特定的队列。
很多意味着在队列中并发推送/轮询
小型异步意味着我希望在包中轮询，比如每个队列中的1到20条消息(这样我就可以启动1.20个异步I/O并等待单线程的完备性)
立即意味着我不想等到20条消息将
浏览 1提问于2014-03-19得票数 1
1回答
我目前正在向类似于服务器的应用程序框架中添加JMS支持。JMS将由HornetQ (服务器类路径上的独立代理、hornetq )实现，但既没有JBoss、spring，也没有提供MDB的其他任何东西。
下一步是将消息侦听器添加到xa队列，该队列将允许对传入消息进行并行处理。有些消息会包含长时间运行的任务，因此基本思想是从onMessage方法生成工作线程。
在我穿越互联网的漫长旅途中，我遇到了，其中一位参与者提到他不会这么做，而是为任务使用额外的内部队列:然后(单线程)消息侦听器只会从入站队列中获取消息并为内部队列创建新消息，在内部队列的另一端，一些工作线程会为传入的消息进行竞争。入站消息一旦
浏览 1提问于2012-12-18得票数 6
回答已采纳
1回答
我对进程间通信很陌生，我正在寻找关于实现以下目标的最佳方法的输入和指导:我有一个功能，可以将图像从一种格式转换为另一种格式，并且我希望使用多个进程进行批处理图像转换。
我有1000幅图像，我想从一种格式转换到另一种格式。
我创建了6个子进程，并希望将图像文件名发送给进程:一个子进程，一个要转换的图像。
我应该简单地创建6个消息队列并向每个进程发送一个消息队列，还是最好创建一个消息队列，存储图像名称的向量，并将该向量发送到6个子进程？
如何将一个子进程的结果传递给父进程？我怎样才能一直把工作发送到这个过程，直到我处理完1000个文件？
我正在使用C++，Windows和学习助推器
浏览 2提问于2014-10-16得票数 0
我正在用Python语言开发一个应用程序，它需要向数组中的所有线程(Python2中的线程模块)发送一个单向消息，当前线程除外。我已经尝试了变量，但这将导致所有线程都响应它，而不是除了发送者之外的所有线程。
以这种方式发送消息的最佳方式是什么？
浏览 2提问于2011-08-11得票数 2
1回答
如何管理托管执行器服务
、、、
我使用托管执行器服务来实现流程管理器，它将在接收到JMS消息事件时处理后台中的任务。通常，会有少量的任务正在运行(可能是10个最大的任务)，但是如果发生了一些事情，并且我的应用程序开始获得100个JMS消息事件，该怎么办？我该如何处理这类事件？
我的想法是，如果可能的话，限制线程的数量，并将所有其他消息保存到数据库中，并在线程可用时运行。提前谢谢。
浏览 5提问于2015-12-14得票数 1
回答已采纳
事件队列是一个获取并处理消息的框。
请您说，PostMessage和SendMessage的消息存储在哪里？以及如何告诉谁发送什么信息？可以检查哪些变量来获取信息？
浏览 2提问于2015-12-07得票数 0
回答已采纳
1回答
我想在我的程序(Linux C)中构造一个sqlite表：
它有3列/字段：
1个ip/端口对、2个FIFO队列指针、3个进程id或线程id
我现在不熟悉sqlite，如果我创建一个sqlite表，是否可以：
当在sqlite表中插入一行时，如果没有预期的事件，则启动一次性超时计时器(当创建行时，第三个字段为null，它等待进程或线程填充thrid字段)。在超时时间内发生，则删除该行。超时计时器是一次性计时器，因此在将行插入到表中后，它只使用一次。
如果有，有没有类似的源代码？谢谢!
浏览 1提问于2013-05-12得票数 0
回答已采纳
2回答
ThreadX包含允许线程间通信的消息队列。假设我有几个线程可以读取和写入队列。我是否必须同步访问这个队列(例如使用互斥)？
浏览 1提问于2014-06-18得票数 1
回答已采纳
我有一个使用MSMQ和NServiceBus进行消息传递的客户端服务器应用程序。在最近的一些测试中，客户端被闲置了一段时间，并发现了MSMQ的意外行为：
MSMQ具有用于处理队列的默认线程数(在注册表中设置为QMThreadNo)。当队列长期处于休眠状态时，它们会积累大量消息。这些大队列保持MSMQ所拥有的线程数量比通常长，因此处理实际处于活动状态的队列需要更长的时间。It可以将注册表项设置为较高的线程count.。
在一段时间内没有发送/接收消息的客户端(在注册表中设置为CleanupInterval)将更改为“非活动”状态，最终将删除它们的队列，直到从该客户端发送消息为止，这将迫使队列
浏览 1提问于2012-03-26得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
