4回答
如何判断一个线程是否有消息队列？
、、、、
有没有办法从threadId中找出一个线程是否有消息队列？
基本上，有一些windows api只有在线程具有消息queue.window时才起作用。
浏览 0提问于2009-11-24得票数 2
回答已采纳
2回答
等待和通知看起来像是在线程之间传递的消息，如果这是真的，那么必须有队列来缓冲这些消息。如果是这样的话，那么必须有原子操作来向队列添加消息和从队列中删除消息，还必须为侦听这些消息的每个Java线程提供一个帮助线程？
很高兴听到你的想法。
浏览 0提问于2013-10-08得票数 10
背景:我需要以异步方式向WebSocket客户端发送许多小规模的消息。消息通常是在峰值发送，所以在暂停之后，我需要快速发送5000条消息。所以问题是：
我不想在单线程中启动5000异步
我不想在串行中循环“启动异步”--“等待完成”5000次
我不想使用5000个线程，使用单个“启动异步”-“等待完成”每个线程
最好的方法是每个线程分组~20异步，所以我需要非常特定的队列。
很多意味着在队列中并发推送/轮询
小型异步意味着我希望在包中轮询，比如每个队列中的1到20条消息(这样我就可以启动1.20个异步I/O并等待单线程的完备性)
立即意味着我不想等到20条消息将
浏览 1提问于2014-03-19得票数 1
事件队列是一个获取并处理消息的框。
请您说，PostMessage和SendMessage的消息存储在哪里？以及如何告诉谁发送什么信息？可以检查哪些变量来获取信息？
浏览 2提问于2015-12-07得票数 0
回答已采纳
2回答
ThreadX包含允许线程间通信的消息队列。假设我有几个线程可以读取和写入队列。我是否必须同步访问这个队列(例如使用互斥)？
浏览 1提问于2014-06-18得票数 1
回答已采纳
在下面的示例中，我将最大和核心池大小设置为1。但是没有处理任何消息。当我启用调试日志时，我能够看到从SQS中提取的消息，但我猜它没有被处理/删除。但是，当我将核心和最大池大小增加到2时，消息似乎会被处理。
编辑
我相信Spring可能会为接收者分配一个线程，用于从队列中读取数据，因此它无法将线程分配给正在处理消息的侦听器。当我将核心池大小增加到2时，我看到消息正在从队列中读取。当我添加另一个侦听器(对于死信队列)时，我遇到了同样的问题--2个线程不够，因为消息没有被处理。当我将核心池大小增加到3时，它开始处理消息。在本例中，我假设分配了一个线程来读取队列中的消息，每个线程分配了两个侦听器。
@
浏览 1提问于2018-04-27得票数 13
回答已采纳
我正在调查，看看骆驼是否能满足以下要求。要求是:传入队列上消息的顺序应该与传出队列上的消息顺序相匹配。
我认为这个问题归结为Camel如何将消息从传入队列转发到传出队列的内部。
在简单的示例中，其中的路由如下所示：
from("incomingQueue").to("outgoingQueue);
incomingQueue有4条消息可以开始(按这个顺序到达)：message 1、message 2、message 3、message 4。
是否有保证或选择告诉骆驼以保持原始接收顺序的方式转发信息？因此，如果侦听器正在侦听传出队列，它将接收消息1，然后是消息2，然后是消
浏览 4提问于2014-08-28得票数 0
回答已采纳
我有以下查询，我需要有人来帮助我with.Im新的消息队列，最近已经开始在Kestrel消息队列。据我所知，线程和消息队列都用于应用程序中的并发，那么使用消息队列相对于多线程有什么优势呢？
请帮帮忙谢谢。
浏览 5提问于2011-01-28得票数 2
回答已采纳
我已经通读了许多关于这个主题的问题，但我找不到任何直接的答案来回答我非常简单的问题:处理程序是否真的创建了新线程，还是只是为创建它们的同一线程创建了一个处理程序？在Android文档中，他们提到：
每个处理程序实例都与一个线程和该线程的消息队列相关联。当您创建一个新的处理程序时，它被绑定到创建它的线程的线程/消息队列--从那时起，它将把消息和可运行程序传送到该消息队列，并在它们从消息队列中出来时执行它们。
然后他们还在同一页上提到：
“处理程序有两个主要用途：(1)在将来的某个时刻调度要执行的消息和runnables；(2)将在不同的线程上执行的操作排入队列。”
我不确定它们是指Handler
浏览 0提问于2016-04-11得票数 3
我有一个使用MSMQ和NServiceBus进行消息传递的客户端服务器应用程序。在最近的一些测试中，客户端被闲置了一段时间，并发现了MSMQ的意外行为：
MSMQ具有用于处理队列的默认线程数(在注册表中设置为QMThreadNo)。当队列长期处于休眠状态时，它们会积累大量消息。这些大队列保持MSMQ所拥有的线程数量比通常长，因此处理实际处于活动状态的队列需要更长的时间。It可以将注册表项设置为较高的线程count.。
在一段时间内没有发送/接收消息的客户端(在注册表中设置为CleanupInterval)将更改为“非活动”状态，最终将删除它们的队列，直到从该客户端发送消息为止，这将迫使队列
浏览 1提问于2012-03-26得票数 1
回答已采纳
我有一个简单的MQTT侦听器，它订阅一个主题并回拨
MqttClient client = new MqttClient(mqttHost, MqttClient.generateClientId());
client.connect();
client.subscribe("test", QUALITY_OF_SERVICE_2, new IMqttMessageListener() {
public void messageArrived(final String s, final Mq
浏览 1提问于2018-03-25得票数 0
回答已采纳
有3个守护进程线程的应用程序和4个单独的应用程序(多处理队列/管道和从队列/管道应用程序读取的3个守护进程线程应用程序)在线程操作功能上是否有区别？
两个应用程序都没有使用阻塞/同步。在一天结束时，操作系统将决定何时允许线程运行和运行多长时间。这里的功能是否有其他的差异，或者它们本质上是相同的？
通用应用程序(没有同步或阻塞)：
“股票市场馈送”队列: StockTrade消息(字典)
'TradingStrategy‘1守护进程线程:从队列中提取、检查消息和执行交易
'TradingStrategy‘1守护进程线程:从队列中提取、检查消息和执行交易
&#
浏览 0提问于2016-10-21得票数 0
2回答
我使用了一些蓝牙库，对于一些蓝牙回调，使用Windows消息循环是必要的。但根据我的要求，我需要创建一个普通的C++程序而不需要任何图形用户界面。有没有可能在没有窗口的情况下创建消息循环？
main(){
Discovery disc;
disc.startDiscovery();
}
Discovery::startDiscovery(){
__hook(&CallBackFromLibrary::OnDiscoveryStarted, &obj, &Discovery::OnDiscoveryStarted);
__hook(&C
浏览 1提问于2018-08-21得票数 2
回答已采纳
发送消息和发布消息(就纯windows编程而言)有什么不同?它们与C#、WPF和纯windows编程有何关系？
我对线程和所有相关的东西都是新手，所以请原谅我有明显的问题。我需要挖掘出线程的外在部分..请让我知道的链接，帮助我建立我的概念，从win32编程到WPF。
我需要理解从Post message到Afx (用于启动新线程的调用)，以便将Invok/Begin Invoke委托给Dispatcher。
浏览 0提问于2010-07-31得票数 74
回答已采纳
1回答
我创建了一个用于通知系统时间更改的WindowProc：
constructor TJJWScheduler.Create;
begin
fTimeChangeWnd := Classes.AllocateHWnd(TimeChangeWndProc);
end;
procedure TJJWScheduler.TimeChangeWndProc(var msg: TMessage);
var
i: integer;
begin
case msg.Msg of
WM_TIMECHANGE:
begin
// my things
e
浏览 2提问于2013-02-14得票数 4
回答已采纳
我无法让我的应用程序响应用户的操作。因此，我希望在多个线程之间拆分消息处理。
我是否可以简单地创建几个线程，从所有线程中读取相同的消息队列，并让哪个线程能够处理每条消息？
如果是这样的话，如何做到这一点？
如果没有，你能提出解决这个问题的另一种方法吗？
浏览 1提问于2009-04-23得票数 3
回答已采纳
2回答
我想用Java编写一个聊天应用程序，使用Swing作为接口。
我想出了一个主意(在的帮助下)，但我不确定这是否是最好的方法。
Blockinqueue线程中有两个main队列，一个用于传入消息，另一个用于传出消息。
有四个线程，两个用于传出，两个用于传入消息，一个用于处理GUI和套接字。
传出消息的线程：
ActionListener (Swing)：是在用户单击GUI中的“发送”时触发的。线程将新消息添加到传出队列并在其上触发notifyAll()。
socketOutgoing：可以访问套接字。使用wait()在传出队列中休眠，直到通知为止。通过套接字在传出队列中发送新消息，然后再
浏览 1提问于2014-01-21得票数 2
回答已采纳
1回答
我正在使用Spring AMQP (RabbitMQ实现)，并尝试将单个事务传播到多个线程中。
例如，假设有3个队列，名为X，Y，Z，首先我使用thread-1从队列X获取一条消息，然后，该消息被提供给thread-0，并且在thread-0中，消息被克隆并通过thread-3发送到队列Y，thread-2和队列Z。线程0等待线程3和线程4的完成，以提交或回滚消息。请注意，我在这里使用了4个线程。
我想要的基本上是处理这3个操作(获取消息并将其放入两个队列)作为单个事务。例如，如果我成功地将消息发送到队列Y，但未能将其发送到Z，则发送到Y的消息将被回滚，原始消息也将被回滚到队列X。
到目前为止
浏览 1提问于2016-09-23得票数 1
我面临一个关于消息队列的问题：
我使用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
我正在尝试让来自windows服务的多个线程(任务)连接到与订阅者相同的队列，这样我就可以更快地处理我的消息。当我连接到我的队列时，我在我的第一个订阅线程上接收消息，其余的都是空闲的。下面是我用来订阅和接收消息的代码：
private MQQueueManager _queueManager;
private MQQueue _queue;
private MQTopic _topic;
public bool isSubscribed = false;
public void Subscribe()
{
var queueManagerName = "myQueueMana
浏览 29提问于2017-03-15得票数 0
2回答
我希望启动一个单独的线程来处理窗口消息(通过阻塞的GetMessage循环)，但之后仍然在初始线程中创建窗口。
在单独的线程中，一旦启动，我将使用PM_NOREMOVE调用PeekMessage，以确保消息队列存在(这是必要的吗？)，然后是..
AttachThreadInput(initial thread id,GetCurrentThreadId(),true)
..before最终进入消息循环
我还没有使用互斥或cs来确保这是及时发生的，但为了简单起见，我只是在我的初始线程中使用了Sleep语句。
无论如何，窗口消息似乎不会被单独的线程截获。
我有点不确定我这样做是否正确，并感谢任何可
浏览 0提问于2009-12-27得票数 6
回答已采纳
众所周知，在UI线程和工作线程之间需要组合的情况下，由于线程安全(句柄重构)，必须创建一个隐藏窗口。
为了举例说明：
Form1有N个动态创建的TProgressBar实例，其名称与后台运行的名称相同。
WM_REFRESH只会在任务线程中被调用。
Form1有分配以下过程的H : THandle property：
过程RefreshStat(var Message: TMessage)；消息WM_REFRESH；
在RefreshStat内部，在只有一个后台线程的情况下，我可以很容易地使用L和W参数来映射任务Id和位置。
我不知道标题是否说了我想知道
浏览 2提问于2013-07-22得票数 1
回答已采纳
3回答
我需要写一种代理服务器，我的设计有点像这样:1.Socket服务器(使用Windows事件选择模型)。程序有一个监听线程监听网络事件。
客户端列表(当前按socketid_list编制索引)。3.套接字服务器接受新的连接，然后为每个客户端创建新的线程。新线程创建到终端目标服务器的套接字连接(需要持久连接)。
我已经编写了套接字服务器，它工作得很好。我的问题是，当新消息从客户端传入时，我如何将此消息传递到相关线程(以便消息可以发送到目标服务器)。
在我的服务器中，我从客户端消息中获取最终目标服务器的地址。我可以从客户端套接字列表中查找客户端套接字。但是我该如何将消息发送到正确的线程呢？
到目前为
浏览 0提问于2011-09-01得票数 2
回答已采纳
1回答
当使用事件驱动的工作处理时，使用AWS、SQS和辅助客户端。经常建议使用长轮询。AWS文档这个这里
本质上，当队列中没有消息时，工作人员不需要不断向队列发出请求(这降低了调用成本)，但新消息仍然会立即传递给正在进行长轮询的工作人员。
现在已经用SQS构建了几次小系统，我怀疑短轮询的好处是什么。我认为它可能会稍微快一些，因为在短轮询时只会对SQS服务器的一个子集进行民意调查，但是如果这是唯一的缺点，我还在看什么额外的延迟呢？这取决于我正在处理的消息的数量吗？( SQS服务器是否根据消息数量进行扩展？)
如果有的话，还有什么其他的坏处？
浏览 0提问于2019-11-21得票数 5
回答已采纳
我知道当发送一条消息时，它具有hwnd值，以便系统知道哪个窗口负责处理该消息。当hwnd为空时，则意味着这是线程消息。那么用来处理该消息的过程函数是什么呢？
浏览 2提问于2012-04-27得票数 0
回答已采纳
2回答
我们正在使用IBM MQ，我们面临着一些严重的问题，关于控制它的异步传递到它的recipient.We已经配置了一些java侦听器，现在的问题是，我们需要控制到达侦听器的消息，因为进入服务器的消息有数百万个，服务器机器没有那么多的容量来同时处理这么多的线程，所以有没有像IBM MQ端的节流一样的方法，我们可以像Apache MQ那样配置预取限制？
或者，有没有其他方法来实现这一点？
目前，当监听器达到某个X限制时，我们正在关闭与IBM MQ的连接，但这似乎不是有效的方法。
请大家帮助我们解决这个问题。
浏览 0提问于2011-07-16得票数 0
1回答
在多读服务器中使用线程
、、、、
我正在编写一个使用消息队列的进程程序之间的Mulithreaded / Server程序。服务器将处理客户端发送的消息，稍后它应该将工作交给一个线程来继续处理它们的it进程。每个客户端都有不同的消息队列。
在建立第一个客户端的连接并使用pthread_join发送一个线程来处理它之后，不允许我接收主线程上的新连接，因为它被阻塞了，我如何修复它。
在主线程(如果可能的话)接收新消息(或其他解决方案)
发送到线程以处理客户端消息的和之后。
回来接收新消息
浏览 0提问于2013-05-13得票数 0
回答已采纳
3回答
我使用boost：：线程来处理队列中的消息。当第一条消息出现时，我启动消息处理线程。当第二条消息出现时，我检查消息处理线程是否已经完成。
如果它完成了，我开始一个新的，如果它不做，我什么也不做。
我如何知道线程是否已经完成？我尝试了连接()，但是它不能工作，就像线程完成时一样，它仍然是可连接的。
我还试图立即中断进程，并在我的线程末尾添加一个中断点，但它没有工作。
谢谢
编辑:
我想让我的线程睡眠一个未定的时间，并醒来时，一个信号被触发。
这样做的手段是boost::condition_variable
浏览 6提问于2010-05-10得票数 4
回答已采纳
1回答
我正在尝试弄清楚WSMQ是如何处理消息侦听器和线程的。如果我有一个消息监听器的实例，并且有许多队列，那么每个监听器是否为每个队列创建一个新线程？或者会有一个线程给监听器吗？任何见解都会有很大的帮助，谢谢。
浏览 2提问于2009-10-06得票数 2
1回答
我在Azure存储中有一个队列，名为“messages”。每1小时，某个服务推送到这个队列，需要更新数据的消息数量。但是，在某些情况下，我也从另一个地方推送到这个队列消息，我希望这个消息被立即进行，并且我不能为这个消息设置优先级。
解决这个问题的最好办法是什么？我是否可以使用两个不同的队列(“消息”和“消息-优先级”)，或者这是一种糟糕的方法？
浏览 2提问于2014-01-19得票数 11
回答已采纳
5回答
我最初问了这个问题，但我已经意识到我的问题不是关于一个短暂的真正循环。我想知道的是，在Java中进行高性能异步消息传递的正确方法是什么？
我想要做的.
我有大约10,000名消费者，每个用户都在使用来自他们私人队列的信息。我有一个线程，它一个接一个地生成消息，并将它们放到正确的消费者队列中。每个使用者无限期地循环，检查要出现在其队列中的消息并对其进行处理。
我相信这个词是“单一生产者/单一消费者”，因为有一个生产者，而且每个消费者只在他们的私有队列上工作(多个消费者从不从同一个队列中读取)。
在Consumer.java内部：
@Override
public void run() {
浏览 8提问于2010-07-29得票数 7
1回答
同步:客户端、服务器聊天
、、、
我正在写一个客户端，基于服务器的聊天。服务器是中心组件，处理所有传入消息和传出消息。客户端是聊天用户。他们可以看到框架中的聊天，也可以写聊天消息。这些消息被发送到服务器。服务器依次更新所有客户端。
我的问题是客户端的同步。由于服务器是多线程的，所以两个消息都可以从客户端接收，并且更新(以消息的形式)也必须发送出去。由于每个客户端都在其自己的线程中进行更新，因此不能保证所有客户端都会收到相同的消息。我们遇到了同步问题。
我该怎么解决呢？
我已经弄乱了时间戳和缓冲区。但这又不是一个好的解决方案，因为不能保证在分配时间戳之后，消息将立即放入缓冲区中。
我应该补充说，我不认识这些客户。也就是说，我在服
浏览 8提问于2013-10-19得票数 0
我试图理解订阅者和发行者缓冲区。如果我将subsrciber缓冲区设置为1000，而publisher缓冲区设置为1，是否存在丢失消息的可能性？有人能跟我解释一下吗？
浏览 8提问于2021-07-21得票数 0
回答已采纳
2回答
多链队列
、
在网络项目中，我有多个对象，每个对象都有一个消息队列(链表)。每个对象也有几个客户端，并且每个客户端都有一个指向队列中节点的指针。当客户端接收到它的指针指向的消息时，它的指针指向队列中的下一条消息。现在，当所有客户端都收到一条消息时，我希望该消息被释放，这样它就不会占用内存。我通过让单独的线程遍历对象并删除不需要的消息来做到这一点，充当GC，但是有没有更好的方法呢？
谢谢。
浏览 0提问于2011-08-25得票数 1
回答已采纳
2回答
队列中是否有任何事件机制或预定义信号。如果队列中有任何数据或消息，队列应该生成一个事件，表示数据已经准备好处理。或者指示其他线程执行他的任务，而不是连续轮询到队列。
在posix消息队列中，有类似于mq_notify()的函数，如果消息队列中有任何数据出现，它将通知其他进程或线程，这样我们就可以避免轮询。
编辑
如果不是，那么我如何在std::queue上实现这一点。我希望避免不断轮询，这样会降低代码的性能。
每当队列上发生某些事件时，它都应该通知其他人。
浏览 4提问于2014-07-02得票数 3
回答已采纳
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
回答已采纳
3回答
我需要知道是否有消息暗示IPC队列是有序的。在实践中，我需要知道当调用msgrvc函数时，是否获得了队列中的第一条消息，或者所选消息是随机的。
现在，我提出这个问题，因为当在代码msgrcv的一部分中得到一条不适合该代码的消息时，我通常会请求消息e在队列中读取以下消息。我想知道的是，举个例子，他会跟踪留言。
msgA，msgB，msgC
，存储在队列中，如果读取msgA并请求它，我将以新的顺序获得带有消息的队列。
msgB，msgC，msgA
因此，下面对msgrcv的调用将给我msgB，或者如果这个顺序是随机的，那么我就可以再读一遍msgA。
谢谢，恩佐
浏览 3提问于2013-07-08得票数 0
1回答
我开始从事Java套接字编程。我已经做了以下应用程序: 1.客户端向服务器发送消息，服务器收到消息后响应2.客户端和服务器像点对点聊天一样聊天
现在我想开发一个应用程序，当一个请求到达服务器时，它将为它生成一个线程。但现在的问题是，我无法识别这些线程。如果一个线程正在发送消息，那么服务器如何识别来自该客户端的消息，我必须将其转发到该客户端。两个客户端(实际上是它们的线程)如何通信？
我在上面搜索，我找到了synchronized关键字，我知道它的用法，我知道wait()，notify()和notifyAll()，但我仍然无法提供它们之间的通信。
如果我做错了什么，或者在跳到这个之前我需要了解一
浏览 0提问于2015-07-25得票数 1
2回答
我正在开发一个多线程应用程序(RAD XE5)。在应用程序开始时，我创建了一个线程，只要主窗体存在，它就会一直存在。
我能够将消息从线程发送到在我的应用程序中创建的任何表单，但是我找不到相反的方法，将消息从主VCL线程发送到工作线程。
在创建主表单时，我创建工作线程并在一个公共变量中复制句柄：
serverThread := TMyThread.Create(True, ServerPort + 1);
serverThreadHandle := serverThread.Handle; // SAVE HANDLE
serverThread.Start;
然后(从另一种形式的Fr
浏览 0提问于2016-10-12得票数 4
回答已采纳
2回答
什么是“线程输入队列”？我在MSDN上见过几次，我可以不再怀疑它是否只是窗口的消息队列，它是由它们所指的线程创建的，还是其他什么的。
举个例子：
WH_MOUSE_LL钩子使您能够监视即将在线程输入队列中发布的鼠标输入事件。
浏览 4提问于2011-12-26得票数 5
回答已采纳
2回答
我对实时操作系统中消息队列的使用感到非常困惑。给出的代码似乎使用了消息队列:甚至将变量传递给另一个类对象也是通过MQ完成的。我总是有一个在IPC中使用的MQ概念。问题是:消息队列的正确用法是什么？
浏览 1提问于2011-05-13得票数 3
回答已采纳
2回答
使用object方法调用是用消息实现的，因此，对象接收消息，如果有对应的消息选择器，则在对象实例上执行该方法。
话虽如此，在流程中是否有消息排队的队列？这是串行队列还是并发队列？这个队列能保证线程安全吗？SingleThreaded公寓)
浏览 3提问于2014-11-23得票数 0
回答已采纳
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
我有一些关于“消息循环”的理论问题；特别是返回在不同线程中运行的消息循环中发生的操作的结果。在这种情况下，我让TCP服务器侦听传入的消息。对于每一条传入消息，服务器将对发送消息的客户端进行身份验证，可能会发生两种情况：
如果经过身份验证的客户端有附加的处理程序，则接收到的消息将被传递到处理程序的消息队列。
如果客户端没有处理程序，将创建一个新的处理程序，并与上面相同(消息将传递到它的消息队列)。
当前，处理程序是一个实现可调用接口的对象，因此它将在一个不同的线程中运行，并且它足够简单地获得操作的结果。现在，对于我的问题:每个处理程序可以处理N个消息。处理程序有一个"me
浏览 1提问于2015-02-05得票数 1
回答已采纳
2回答
我有一个自定义类的对象实例，每个实例独立地处理传入的消息(通过方法)。没有实例与其他实例“对话”。
我的问题是，将每个对象放在自己的线程中是否有必要，因为每个对象都独立地处理实时消息(日志等)。不管怎么说，你是不是来了？
感谢您的回复。
浏览 0提问于2013-07-04得票数 1
回答已采纳
我有一个客户端套接字列表，通常大小在2000左右。这些客户是动态的，他们来来往往。
我有一个由32个线程组成的固定线程池的ExecutorService来处理这些线程。此执行器服务负责解码和发送要发送给这2000客户端的消息。
我希望防止执行器服务的两个(或更多)线程同时处理同一个客户端。
一种方法可以是引入另一个簿记线程(因此我最终得到32 +1个线程)，它负责在完成与同一个客户端对应的前一条消息时调用ExecutorService.submit(mesage)。但我不确定这是否会引入瓶颈，这意味着这个新引入的簿记线程无法继续提交消息。
理想情况下，我不希望预先将线程分配给一组客户端，因为消
浏览 0提问于2018-08-14得票数 3
回答已采纳
注意，首先，这个问题不是标记为或或任何其他特定于GUI的问题。这是有意的，你很快就会看到。
第二，如果这个问题有点长，很抱歉。我试着把四处飘浮的各种信息拼凑起来，以便提供有价值的信息。然而，我的问题就在“我想知道的”下面。
我的任务是最终了解.NET提供的在特定线程上调用委托的各种方式。
我想知道的是：
我正在寻找最通用的方法(不是Winforms或WPF特定的)来调用特定线程上的委托。
或者，不同的措辞:我会感兴趣的是，以及如何通过各种方式(比如通过WPF的Dispatcher)来利用彼此；也就是说，是否有一种通用的跨线程委托调用机制是所有其他人都使用的。
我已经
浏览 4提问于2011-01-30得票数 12
回答已采纳
长话短说:在使用COM inproc-server (dll)的C#应用程序中，我遇到了"0x80010100:系统调用失败“异常，在调试模式下也遇到了ContextSwitchDeadlock异常。
现在更详细地说：
1) C# app初始化STA，创建一个COM对象(注册为“公寓”)；然后在订阅它的连接点，并开始使用该对象。
2)在某些阶段，COM对象生成许多事件，将在同一单元中创建的COM对象的一个非常大的集合作为参数传递。
3) C#端的事件处理程序处理上述集合，偶尔调用对象的一些方法。在某些阶段，后一种调用开始失败，出现上述异常。
在COM方面，公寓使用了一个隐藏窗口，其wi
浏览 6提问于2012-02-21得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
