admin 发表于 2022-3-14 20:04:16

线程池组件接口

hpsocket线程池组件接口
HP-Socket v5.4.x 版本开始,提供线程池组件 IHPThreadPool,协助用户实现通信逻辑与
业务逻辑分离,提高应用程序的整体执行效率。IHPThreadPool 提供以下主要操作方法。这
些方法成功返回 TRUE,失败返回 FALSE,失败可通过 SYS_GetLastError() 获取系统错误代
码。
 启动线程池
BOOL Start(dwThreadCount = 0, dwMaxQueueSize = 0, enRejectedPolicy =
TRP_CALL_FAIL, dwStackSize = 0)
✓ dwThreadCount 线程数量,(默认:0)
>0 :dwThreadCount
=0 :(CPU 核数 * 2 + 2)
<0 :(CPU 核数 * (-dwThreadCount))
✓ dwMaxQueueSize 任务队列最大容量(默认:0,不限制)
✓ enRejectedPolicy 任务拒绝处理策略
TRP_CALL_FAIL :(默认)立刻返回失败
TRP_WAIT_FOR :等待(直到成功、超时或线程池关闭等原因导致失败)
TRP_CALLER_RUN :调用者线程直接执行
✓ dwStackSize 线程堆栈空间大小(默认:0 -> 操作系统默认)
 关闭线程池
在规定时间内关闭线程池组件,如果工作线程在最大等待时间内未能正常关闭,会尝试
强制关闭,这种情况下很可能会造成系统资源泄漏。IHPThreadPool
+Start()
+Stop()
+Wait()
+Submit()
+Submit()
+AdjustThreadCount()
+HasStarted()
+GetState()
+GetQueueSize()
+GetTaskCount()
+GetThreadCount()
+GetMaxQueueSize()
+GetRejectedPolicy()
<<destroy>>+IHPThreadPool()
BOOL Stop(dwMaxWait = INFINITE)
✓ dwMaxWait 最大等待时间(毫秒,默认:INFINITE,一直等待)
 提交任务
BOOL Submit(fnTaskProc, pvArg, dwMaxWait = INFINITE)
✓ fnTaskProc 任务处理函数
✓ pvArg 任务参数
✓ dwMaxWait 任务提交最大等待时间(毫秒,仅对 TRP_WAIT_FOR 类型线程
池生效,默认:INFINITE,一直等待)。
** SYS_GetLastError() 错误码 ERROR_DESTINATION_ELEMENT_FULL 表示
任务队列已满。
 提交 Socket 任务
BOOL Submit(pTask, dwMaxWait = INFINITE)
✓ pTask 任务参数
✓ dwMaxWait 任务提交最大等待时间(毫秒,仅对 TRP_WAIT_FOR 类型线程
池生效,默认:INFINITE,一直等待)
** SYS_GetLastError() 错误码 ERROR_DESTINATION_ELEMENT_FULL 表示
任务队列已满。
注意:pTask 由 HP_Create_SocketTaskObj( )函数创建,当 Submit(pTask)提交成功
时 线 程 池 负 责 自 动 销 毁 pTask 对 象 ; 当 提 交 失 败 时 应 用 程 序 需 要 手 工 调 用
HP_Destroy_SocketTaskObj( )销毁 pTask 对象。
 动态调整线程池大小
BOOL AdjustThreadCount(dwNewThreadCount)
✓ dwNewThreadCount 线程数量
>0 :dwNewThreadCount
=0 :(CPU 核数 * 2 + 2)
<0 :(CPU 核数 * (-dwNewThreadCount))
页: [1]
查看完整版本: 线程池组件接口