PostThreadMessageA 发送消息丢失，附带完整的程序示例

caojianfei

之前发帖询问 PostThreadMessageA 消息丢失问题，没有上传完整的程序可能大家不是很能理解我在说什么，这次我上传了一个示例程序，能复现我的问题。程序启动之后先点击创建线程，然后点击发送消息，发送消息点击足够快，大于子线程的处理时间，那这个消息发送成功但是无法被子线程接收到

主要代码如下：

  

窗口程序集名	保 留	保 留	备 注
窗口程序集_启动窗口
变量名	类 型	数组	备 注
线程ID	整数型
线程句柄	整数型

子程序名	返回值类型	公开	备 注
_按钮_创建线程_被单击

如果真 (线程句柄 ＞ 0)
信息框 (“线程已启动”, 0, , _启动窗口.取窗口句柄 ())
返回 ()

启动线程 (&线程程序, , 线程句柄)

子程序名	返回值类型	公开	备 注
线程程序

变量名	类 型	静态	数组	备 注
死循环	逻辑型
接收消息	整数型
msg	消息结构

如果真 (线程ID ＞ 0)
返回 ()

调试输出 (“线程已启动，线程ID：” ＋ 到文本 (线程ID))
线程ID ＝ 线程_取自线程ID ()
死循环 ＝ 真
判断循环首 (死循环)
接收消息 ＝ GetMessage (msg, -1, 0, 0)
调试输出 (“接收消息结果：” ＋ 到文本 (接收消息))
如果真 (接收消息 ＝ 0)
线程ID ＝ 0
线程句柄 ＝ 0
跳出循环 ()

调试输出 (“=============== 接收到消息 ==============”)
' 调试输出 (“message:” ＋ 到文本 (msg.message))
调试输出 (“hwnd：” ＋ 到文本 (msg.hwnd))
调试输出 (“message：” ＋ 到文本 (msg.message))
调试输出 (“wParam：” ＋ 到文本 (msg.wParam))
调试输出 (“lParam：” ＋ 到文本 (msg.lParam))
调试输出 (“time：” ＋ 到文本 (msg.time))
调试输出 (“pt_x：” ＋ 到文本 (msg.pt_x))
调试输出 (“pt_y：” ＋ 到文本 (msg.pt_y))
调试输出 (“=============== 接收到消息 END ==============”)
程序_延时 (2000)
判断循环尾 ()

子程序名	返回值类型	公开	备 注
_按钮_发送消息_被单击

变量名	类 型	静态	数组	备 注
消息发送结果	整数型

如果真 (线程ID ≤ 0)
信息框 (“请先启动线程”, 0, , _启动窗口.取窗口句柄 ())
返回 ()

消息发送结果 ＝ PostThreadMessageA (线程ID, 2000, 1, 2)
调试输出 (“消息发送结果:” ＋ 到文本 (消息发送结果))

子程序名	返回值类型	公开	备 注
_按钮_停止线程_被单击

如果真 (线程ID ≤ 0)
信息框 (“请先启动线程”, 0, , _启动窗口.取窗口句柄 ())
返回 ()

PostThreadMessageA (线程ID, 18, 1, 2)

子程序名	返回值类型	公开	备 注
__启动窗口_创建完毕

i支持库列表	支持库注释
EThread	多线程支持库
spec	特殊功能支持库

.版本 2<br /> .支持库 EThread<br /> .支持库 spec<br /> <br /> .程序集 窗口程序集_启动窗口<br /> .程序集变量 线程ID, 整数型<br /> .程序集变量 线程句柄, 整数型<br /> <br /> .子程序 _按钮_创建线程_被单击<br /> <br /> .如果真 (线程句柄 ＞ 0)<br />     信息框 (“线程已启动”, 0, , _启动窗口.取窗口句柄 ())<br />     返回 ()<br /> .如果真结束<br /> <br /> 启动线程 (&线程程序, , 线程句柄)<br /> <br /> <br /> .子程序 线程程序<br /> .局部变量 死循环, 逻辑型<br /> .局部变量 接收消息, 整数型<br /> .局部变量 msg, 消息结构<br /> <br /> .如果真 (线程ID ＞ 0)<br />     返回 ()<br /> .如果真结束<br /> <br /> 调试输出 (“线程已启动，线程ID：” ＋ 到文本 (线程ID))<br /> <br /> 线程ID ＝ 线程_取自线程ID ()<br /> 死循环 ＝ 真<br /> .判断循环首 (死循环)<br /> <br />     接收消息 ＝ GetMessage (msg, -1, 0, 0)<br />     调试输出 (“接收消息结果：” ＋ 到文本 (接收消息))<br />     .如果真 (接收消息 ＝ 0)<br />         线程ID ＝ 0<br />         线程句柄 ＝ 0<br />         跳出循环 ()<br />     .如果真结束<br /> <br />     调试输出 (“=============== 接收到消息 ==============”)<br />     ' 调试输出 (“message:” ＋ 到文本 (msg.message))<br />     调试输出 (“hwnd：” ＋ 到文本 (msg.hwnd))<br />     调试输出 (“message：” ＋ 到文本 (msg.message))<br />     调试输出 (“wParam：” ＋ 到文本 (msg.wParam))<br />     调试输出 (“lParam：” ＋ 到文本 (msg.lParam))<br />     调试输出 (“time：” ＋ 到文本 (msg.time))<br />     调试输出 (“pt_x：” ＋ 到文本 (msg.pt_x))<br />     调试输出 (“pt_y：” ＋ 到文本 (msg.pt_y))<br />     调试输出 (“=============== 接收到消息 END ==============”)<br /> <br />     程序_延时 (2000)<br /> <br /> .判断循环尾 ()<br /> <br /> .子程序 _按钮_发送消息_被单击<br /> .局部变量 消息发送结果, 整数型<br /> <br /> .如果真 (线程ID ≤ 0)<br />     信息框 (“请先启动线程”, 0, , _启动窗口.取窗口句柄 ())<br />     返回 ()<br /> .如果真结束<br /> <br /> 消息发送结果 ＝ PostThreadMessageA (线程ID, 2000, 1, 2)<br /> 调试输出 (“消息发送结果:” ＋ 到文本 (消息发送结果))<br /> <br /> .子程序 _按钮_停止线程_被单击<br /> <br /> .如果真 (线程ID ≤ 0)<br />     信息框 (“请先启动线程”, 0, , _启动窗口.取窗口句柄 ())<br />     返回 ()<br /> .如果真结束<br /> <br /> PostThreadMessageA (线程ID, 18, 1, 2)<br /> <br /> .子程序 __启动窗口_创建完毕

我的疑问主要在于子线程接收消息那一块，也就是 线程程序 这个方法中，如果接收到消息开始进行业务处理，假设这个业务处理耗时 2 秒，那么这 2 秒时间内，发送给线程的消息都无法被接收到，相当于丢失了，想咨询一下论坛的大佬这是为什么？如何解决？

frankiy

还是那句话，建议你做消息池。

caojianfei

frankiy 发表于 2025-2-27 15:21
还是那句话，建议你做消息池。

感谢大佬的回答，不过我还是有一个疑问，PostThreadMessageA 目标线程忙碌的时候，投递的消息是直接被丢弃吗？

frankiy

caojianfei 发表于 2025-2-27 16:38
感谢大佬的回答，不过我还是有一个疑问，PostThreadMessageA 目标线程忙碌的时候，投递的消息是直接被丢 ...

实际上向线程投递消息，系统是自带缓冲池的，一次取一个消息。

你可以参考getmessage 的官方说明文档。

frankiy

caojianfei 发表于 2025-2-27 16:38
感谢大佬的回答，不过我还是有一个疑问，PostThreadMessageA 目标线程忙碌的时候，投递的消息是直接被丢 ...

不过，我最大的建议就是， getMessage 的进程，一定要和事件处理进程分开！  因为getMessage进程在没有消息时，会一直挂起！一直到获取到消息！ 这样会造成整个线程的堵塞！

caojianfei

frankiy 发表于 2025-2-27 17:10
实际上向线程投递消息，系统是自带缓冲池的，一次取一个消息。

你可以参考getmessage 的官方说明文档。 ...

我看了官方 PostThreadMessageA   GetMessage 的文档好多遍，也尝试了 PeekMessage, 甚至问了好多遍 DeepSeek，但是得到的结果是消息不会丢失，而且很显然我的消息队列没有满，所以我才奇怪为什么连续发送消息会丢失。不过您提供的方案也可以实现我的需求，只不过消息数组会无限增大，不是特别好处理，要删除消息数组还得上锁，这样又降低了并发效率。如果他原生的消息队列可以支持是最好的