1回答
我们正在运行Fedora 14，并使用消息队列向线程传递数据和从线程传递数据。问题是我们创建了一个消息队列：其中：sQAttr.mq_flags = 0;
sQAttr.mq_maxmsg = iMaxNumMes
浏览 5提问于2011-07-07得票数 1
回答已采纳
我使用Websphere MQ 6在AIX6.1上运行了一个C应用程序。主C应用程序生成一个独立的线程，该线程执行循环以从队列中获取消息。当CTRL被击中时，有一个关闭钩子(通过信号)，它优雅地将“线程运行变量”设置为FALSE，线程结束。问题是，每当我访问CTRL时，我都会得到以下原因代码：因此，即使Websphere MQ上的MQGET当前正在运行，当我点击CTRL-C时，是否需要将
浏览 4提问于2011-11-10得票数 2
回答已采纳
我在多线程应用程序中使用MQ，其中多个工作线程通过循环调用MQGET ( MQGMO_WAIT设置为MQWI_UNLIMITED，等待间隔为MQWI_UNLIMITED)处理来自自己队列的传入消息。它可以工作，但我找不到一个干净的方法来关闭工作线程。如果我在另一个线程中调用MQDISC或MQCLOSE，则每当有未执行的MQGET调用时，它都会阻塞。目前，我最好的解决方案是使用5000的有限等待间隔，而不是MQWI_UNLIMITED，这样MQGET调用每5秒就会返回一次，给应用程序<em
浏览 6提问于2016-05-02得票数 1
回答已采纳
我们使用IBM，这是输出dspmqver：Version: 8.0.0.14Platform: WebSphere MQ for Linux (x86-64 platform)DataPath: /var/mqmLicense
浏览 17提问于2020-04-22得票数 0
1回答
我想要“发送一个消息”从一个线程到主程序扫描，我问如何给予“扫描”函数，或"cin“函数，一些东西停止等待。
你通常会在控制台上写一些东西，然后按下"enter“键。我怎么能从另一个线程中做同样的事情呢？
浏览 5提问于2014-12-20得票数 0
回答已采纳
我有： ...mq (pub/sub) mq.close();现在我正在使用一个监视控制台，我看到：
再过几秒钟，只有一个线程MQTT调用。调用线程将
浏览 3提问于2013-09-25得票数 2
2回答
我们正在使用IBM MQ，我们面临着一些严重的问题，关于控制它的异步传递到它的recipient.We已经配置了一些java侦听器，现在的问题是，我们需要控制到达侦听器的消息，因为进入服务器的消息有数百万个，服务器机器没有那么多的容量来同时处理这么多的线程，所以有没有像IBM MQ端的节流一样的方法，我们可以像Apache MQ那样配置预取限制？目前，当监听器达到某个X限制时，我们正在关闭与IBM MQ的连接，但这似乎不是有效的方法。
请大家帮助我们解决这个问题。
浏览 0提问于2011-07-16得票数 0
我的订单处理服务器侦听两个队列(在一个线程中)。队列1-网关服务器，队列2-清除服务器。java.lang.OutOfMemoryError: un
浏览 3提问于2013-11-28得票数 0
回答已采纳
2回答
我做了一个从MSMQueue读取消息的Windows服务，我需要并行地做这件事(两个线程应该同时读取消息)。我该怎么做呢？基本上是照本宣科)： { mq</
浏览 2提问于2013-05-01得票数 2
我正在执行下面的ActiveMq程序，将文件放入队列。 FileInputStream in; ActiveMQConnectio
浏览 0提问于2013-07-10得票数 2
回答已采纳
1回答
我目前正在开发一个嵌入式应用程序(运行在linux 4.14上)，它使用POSIX线程实现两个线程(主线程和一个通信线程)。通信线程创建一个POSIX队列来处理来自主线程的命令请求(通过调用mq_send())。它还可以处理来自引发SIGIO信号的串行线的输入数据。= 0; attr.mq_msgsize = sizeof(struct Dummy);
浏览 0提问于2020-02-05得票数 1
异常显示为- MQException: MQJE001: An MQException occurred:完成代码2，原因2009 MQJE016: MQ队列管理器在连接关闭原因= 2009期间立即关闭了通道= Integer.parseInt(ConfigFileLoader.getProperty("MQ_PORT"));
tradeLogger.info(logStr + "MQHOST NAME : " + MQEnvironment.ho
浏览 104提问于2021-02-02得票数 0
2回答
我试图编写一个消息队列实现，这样我的线程就可以交换数据。为了保持简单，队列只负责发送指向内存的指针。只有一个线程可以发送消息，只有一个线程可以读取消息。mq_t.send是上一次发送消息的索引。线程安全:我没有使用互斥锁或锁，但我认为代码非常线程安全。这是真的吗？
在代码中，我使用像
浏览 0提问于2013-08-03得票数 6
回答已采纳
我想我描述了我所需要的几乎所有的标题。所以有一些WMB流。一个人在队列中等待答案。如果超时后队列中没有消息，我需要抛出异常。
浏览 1提问于2017-02-02得票数 0
回答已采纳
我的应用程序崩溃是因为“无法关闭未初始化的Msg”未处理的异常。这可能是由于从多个线程访问套接字造成的。我在调试这个问题时遇到了问题，因为当我检查我的代码时，所有对套接字的访问都是在poller线程中完成的--或者直接在ReceiveReady事件处理程序中(据我所理解，它是在poller线程上运行)，或者在手动创建的代码示例--正如我所写的，我只使用了两个“模式”： private async void OnMessa
浏览 4提问于2017-07-26得票数 0
回答已采纳
3回答
我正在尝试让线程A与线程B进行通信。我应该使用线程之间的消息传递来实现这一点，但我正在尝试找到一些解释消息传递的示例源代码。
有没有人有很好的链接到一些解释消息传递的示例源代码(C语言)？
浏览 0提问于2011-11-24得票数 6
回答已采纳
我有一个应用程序，它将三个进程分叉，并通过这些事件管理一个进程的线程工作池。
我对这个问题有多种解决办法。一种是使用Linux上的mkfifo在linux上创建FIFO特殊文件，并使用select语句唤醒线程。问题是，这个解决方案的工作方式与WaitForMultipleObjects不同。例如，如果工作池的10个线程将等待事件，并且我调用了5次SetEvent，那么正好有5个工作线程将唤醒并完成工作，当在Linux中使用fifo变量时，它会唤醒每个线程，即我在select语句中，并等待数据被放入
浏览 2提问于2016-02-08得票数 3
回答已采纳
2回答
我使用POSIX队列(mqueue)在线程之间进行通信。 n = mq_receive(mqdes, buf, mqAttr.mq_msgsize, NULL);printf(&qu
浏览 4提问于2012-11-13得票数 4
1回答
max连接问题
、、、
我有一个Java客户端，它用10个连接连接到MQ。它们在Java客户端运行期间保持开放状态。对于每个线程，我们创建一个消息，创建一个会话，发送消息并关闭会话。我们的MQ工程团队告诉我们，我们的队列管理器的最大连接是500个，而且我们的连接超过了这个值。因此，我想知道的是，在MQ术语中，jms连接和会话等同于什么？我确实认为连接等同于活动通道，会话是句柄，所以当我们打开(和关闭)会话的数量达到数百或数千次时，句柄可能会超过句柄，而我们只有10个连接。任何关于如何最好地配置MQ</e
浏览 2提问于2014-07-09得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
