帮忙看下这个队列有没有问题

764693871

队列还看不懂，线程池这个感觉简单点

764693871

Suky 发表于 2025-7-22 22:29
你要的是队列，但是你写的是多线程线程池
这跟队列是两码事
方向错了

懂了，队列就是压数据，然后只启动一个子程序死循环判断是否有队列，有就弹数据，是这个意思吧

2224848

你在线程池回调函数中使用了_读内存文本(局_参数)，但没有对内存释放进行保护，当多个线程同时操作同一块内存区域时，可能会出现内存访问冲突，在按钮点击事件中，你使用了循环变量i，但它没有被正确初始化和递增，每次点击按钮时，i的值都是未定义的，导致消息内容可能重复，使用_写内存文本分配的内存没有对应的释放机制，长时间运行会导致内存泄漏。

修改后的代码可以尝试一下：

  

窗口程序集名	保 留	保 留	备 注
窗口程序集_启动窗口
变量名	类 型	数组	备 注
线程池	鱼刺类_线程池Ex
互斥锁	整数型
消息队列	文本型	待发送的消息队列
当前索引	整数型

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

线程池.创建 (1, 1)  ' 单线程模式，确保顺序执行
互斥锁 ＝ 互斥锁_创建 ()
当前索引 ＝ 0

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

变量名	类 型	静态	数组	备 注
局_消息内容	文本型
i	整数型

' 正确初始化循环变量
i ＝ 当前索引 + 1
当前索引 ＝ i

局_消息内容 ＝ “呵呵哒” ＋ 到文本 (i)

' 使用互斥锁保护队列操作
互斥锁_锁定 (互斥锁)
加入成员 (消息队列, 局_消息内容)
互斥锁_解锁 (互斥锁)

' 投递消息处理任务
线程池.投递任务 (&处理消息队列, 0)

子程序名	返回值类型	公开	备 注
处理消息队列
参数名	类 型	参考	可空	数组	备 注
局_参数	整数型

变量名	类 型	静态	数组	备 注
待发送消息	文本型

互斥锁_锁定 (互斥锁)

' 检查队列是否有消息
如果真 (取数组成员数 (消息队列) > 0)
待发送消息 ＝ 消息队列 [1]
删除成员 (消息队列, 1)
互斥锁_解锁 (互斥锁)

' 执行实际发送消息的操作
发送消息 (待发送消息)
互斥锁_解锁 (互斥锁)

子程序名	返回值类型	公开	备 注
发送消息
参数名	类 型	参考	可空	数组	备 注
消息内容	文本型

变量名	类 型	静态	数组	备 注
文本指针	整数型

' 分配内存存储消息
文本指针 ＝ _写内存文本 (消息内容)

' 这里添加实际发送消息的代码
调试输出 ("发送消息: " & _读内存文本 (文本指针))

' 释放内存
释放内存 (文本指针)

i支持库列表	支持库注释
spec	特殊功能支持库

.版本 2<br /> .支持库 spec<br /> <br /> .程序集 窗口程序集_启动窗口<br /> .程序集变量 线程池, 鱼刺类_线程池Ex<br /> .程序集变量 互斥锁, 整数型<br /> .程序集变量 消息队列, 文本型, , "待发送的消息队列"<br /> .程序集变量 当前索引, 整数型, "当前处理的消息索引"<br /> <br /> .子程序 __启动窗口_创建完毕<br />     线程池.创建 (1, 1)  ' 单线程模式，确保顺序执行<br />     互斥锁 ＝ 互斥锁_创建 ()<br />     当前索引 ＝ 0<br /> <br /> .子程序 _按钮1_被单击<br /> .局部变量 局_消息内容, 文本型<br /> .局部变量 i, 整数型<br /> <br />     ' 正确初始化循环变量<br />     i ＝ 当前索引 + 1<br />     当前索引 ＝ i<br />     <br />     局_消息内容 ＝ “呵呵哒” ＋ 到文本 (i)<br />     <br />     ' 使用互斥锁保护队列操作<br />     互斥锁_锁定 (互斥锁)<br />     加入成员 (消息队列, 局_消息内容)<br />     互斥锁_解锁 (互斥锁)<br />     <br />     ' 投递消息处理任务<br />     线程池.投递任务 (&处理消息队列, 0)<br /> <br /> .子程序 处理消息队列<br /> .参数 局_参数, 整数型<br /> .局部变量 待发送消息, 文本型<br /> <br />     互斥锁_锁定 (互斥锁)<br />     <br />     ' 检查队列是否有消息<br />     .如果真 (取数组成员数 (消息队列) > 0)<br />         待发送消息 ＝ 消息队列 [1]<br />         删除成员 (消息队列, 1)<br />         互斥锁_解锁 (互斥锁)<br />         <br />         ' 执行实际发送消息的操作<br />         发送消息 (待发送消息)<br />     .否则<br />         互斥锁_解锁 (互斥锁)<br />     .如果真结束<br /> <br /> .子程序 发送消息<br /> .参数 消息内容, 文本型<br /> .局部变量 文本指针, 整数型<br /> <br />     ' 分配内存存储消息<br />     文本指针 ＝ _写内存文本 (消息内容)<br />     <br />     ' 这里添加实际发送消息的代码<br />     调试输出 ("发送消息: " & _读内存文本 (文本指针))<br />     <br />     ' 释放内存<br />     释放内存 (文本指针)

[color=rgba(0, 0, 0, 0.85)]这样修改后，代码可以安全地实现 "一次给一个人发一条消息" 的需求，避免了内存冲突和泄漏问题。如果实际发送消息涉及网络操作，建议在发送消息[color=rgba(0, 0, 0, 0.85)]子程序中添加错误处理和重试机制。

禁回忆

队列是队列，多线程是多线程。
队列是先进先出的数据结构，可以保证处理顺序。
多线程是随机的，你还要处理各种锁相关的问题，线程是非常珍贵的资源，也不应该用在这方面

补充内容 (2025-7-23 08:54):
另外你写到内存的指针需要手动释放