类_线程池1 投递任务 2个问题 需改进啊 附自己改造后的代码

HugBear

问题1：投递任务 超时设置是等待线程[1]执行完成，如果超时还没有完成  就 TerminateThread 终止 重新启动一条线程工作 这个不是很好 有些时候需要实现的功能有点繁杂，涉及到有失败重试次数的问题，线程所占用的时间会稍微多一些。投递任务 超时为无限等待：如果线程[1]所占用的时间 是其他线程稍长一点就会发现一个现象 创建时设置的线程数是10 当全部线程都已经完成工作  这时线程[1]执行完成了 这时候才会投递成功，这时候线程池跟首次启动一样 0条线程在工作


问题2：投递任务  不设置超时 将会不停的closehandle 线程[1]的线程句柄 然后启动新线程  即便实际执行的线程数量已经超过了 类方法 创建时所设置的线程数量


{:soso_e117:}以下是改造版,设置超时 则投递任务失败. 动态判断线程是否已经完成任务 比较能正确的保证线程与创建设置时的线程数量一致 上次用来写一个外国游戏的扫好器 发现类_线程池1 存在的问题，自己改过之后 拿来分享下吧。 再次感谢精易模块开源行为。

guazi

没玩过 玩玩看

HugBear

我叫林舒书 发表于 2013-11-3 22:44
表示我也没收到，我也想看看他这个怎么改。@小磊

每月1号。。

我叫林舒书

维卷残恋 发表于 2013-11-3 22:13
苦比了。。为啥我没收到开源邮件。。

表示我也没收到，我也想看看他这个怎么改。@小磊

HugBear

我叫林舒书 发表于 2013-11-3 22:09
貌似已经更新了

苦比了。。为啥我没收到开源邮件。。

我叫林舒书

维卷残恋 发表于 2013-11-2 22:31
这个我是复制从精易模块内那个类_线程池1 只有部分代码改写的 等小磊下次更新发出来再看看吧，

貌似已经更新了

HugBear

我叫林舒书 发表于 2013-11-2 20:40
感觉楼主的写法还是有问题。

处理数组的时时候，删除了成员，继续循环的话可能会出错，修改了下还有一 ...

这个我是复制从精易模块内那个类_线程池1 只有部分代码改写的 等小磊下次更新发出来再看看吧，

我叫林舒书

有点乱  上面的两个代码

[e]
.版本 2
.支持库 spec

.子程序 投递任务_新, 整数型, 公开, 往线程池中投递一个任务，返回线程句柄
.参数 函数, 子程序指针
.参数 参数, 整数型, 可空
.参数 超时, 整数型, 可空, 留空，则无限等待
.局部变量 线程个数, 整数型
.局部变量 线程句柄, 整数型
.局部变量 当前时间, 整数型
.局部变量 状态值, 整数型

.如果真 (集_停止)
    返回 (0)
.如果真结束
当前时间 ＝ 取启动时间 ()
.判断循环首 (真)
    线程个数 ＝ 取数组成员数 (集_线程句柄)
    .判断开始 (线程个数 ＞ 集_线程数量)
        .计次循环首 (线程个数, )
            状态值 ＝ 内部_取线程状态 (集_线程句柄 [线程个数])
            .如果真 (状态值 ＜ 2)
                TerminateThread (集_线程句柄 [线程个数], 0)
                CloseHandle (集_线程句柄 [线程个数])
                删除成员 (集_线程句柄, 线程个数, )
                跳出循环 ()
            .如果真结束
            线程个数 ＝ 线程个数 － 1
        .计次循环尾 ()
    .默认
        跳出循环 ()
    .判断结束

    .如果真 (超时 ＞ 0)
        .如果真 (取启动时间 () － 当前时间 ＞ 超时)
            返回 (0)
        .如果真结束

    .如果真结束
    处理事件 ()
    延迟 (50)
.判断循环尾 ()
线程句柄 ＝ CreateThread (0, 0, 到整数 (函数), 参数, 0, 0)
加入成员 (集_线程句柄, 线程句柄)
返回 (线程句柄)
[/e]

[e]
.版本 2

.子程序 置线程数, , 公开, 设置新线程数量
.参数 线程数量, 整数型

集_停止 ＝ 真
集_线程数量 ＝ 线程数量 － 1
集_停止 ＝ 假
[/e]

我叫林舒书

小磊 发表于 2013-10-29 14:00
你这个写法，我以前用过，后来忘记是什么原因改成了现在这样，这样的话我会先并存一下

感觉楼主的写法还是有问题。

处理数组的时时候，删除了成员，继续循环的话可能会出错，修改了下

1. .版本 2
   
2. .支持库 spec
   
3. 
   
4. .子程序 投递任务_新, 整数型, 公开, 往线程池中投递一个任务，返回线程句柄
   
5. .参数 函数, 子程序指针
   
6. .参数 参数, 整数型, 可空
   
7. .参数 超时, 整数型, 可空, 留空，则无限等待
   
8. .局部变量 线程个数, 整数型
   
9. .局部变量 线程句柄, 整数型
   
10. .局部变量 当前时间, 整数型
    
11. .局部变量 状态值, 整数型
    
12. 
    
13. .如果真 (集_停止)
    
14.     返回 (0)
    
15. .如果真结束
    
16. 当前时间 ＝ 取启动时间 ()
    
17. .判断循环首 (真)
    
18.     线程个数 ＝ 取数组成员数 (集_线程句柄)
    
19.     .判断开始 (线程个数 ＞ 集_线程数量)
    
20.         .计次循环首 (线程个数, )
    
21.             状态值 ＝ 内部_取线程状态 (集_线程句柄 [线程个数])
    
22.             .如果真 (状态值 ＜ 2)
    
23.                 TerminateThread (集_线程句柄 [线程个数], 0)
    
24.                 CloseHandle (集_线程句柄 [线程个数])
    
25.                 删除成员 (集_线程句柄, 线程个数, )
    
26.                 跳出循环 ()
    
27.             .如果真结束
    
28.             线程个数 ＝ 线程个数 － 1
    
29.         .计次循环尾 ()
    
30.     .默认
    
31.         跳出循环 ()
    
32.     .判断结束
    
33. 
    
34.     .如果真 (超时 ＞ 0)
    
35.         .如果真 (取启动时间 () － 当前时间 ＞ 超时)
    
36.             返回 (0)
    
37.         .如果真结束
    
38. 
    
39.     .如果真结束
    
40.     处理事件 ()
    
41.     延迟 (50)
    
42. .判断循环尾 ()
    
43. 线程句柄 ＝ CreateThread (0, 0, 到整数 (函数), 参数, 0, 0)
    
44. 加入成员 (集_线程句柄, 线程句柄)
    
45. 返回 (线程句柄)
    

复制代码

还有一个问题，就是线程池执行的时候不能改变线程数，能不能加个置线程数

1. .版本 2
   
2. 
   
3. .子程序 置线程数, , 公开, 设置新线程数量
   
4. .参数 线程数量, 整数型
   
5. 
   
6. 集_停止 ＝ 真
   
7. 集_线程数量 ＝ 线程数量 － 1
   
8. 集_停止 ＝ 假
   

复制代码

小磊

你这个写法，我以前用过，后来忘记是什么原因改成了现在这样，这样的话我会先并存一下