TThreadPool 线程池基类 主要负责线程初始化 与管理任务队列 不管理线程自身
主要方法2个构造函数
TThreadPool.Create(ThreadCount: Integer = MAX_THREAD_COUNT; MaxWork:
Integer = MAX_QUEUE_WORK_COUNT);
初始化线程数量 并设置最大值 最大值也用于工作队列
InitPool(ThreadCount); 具体设置工作队列
TThreadPool.Create(ThreadClass: TThreadClass; ThreadCount: Integer; MaxWork: Integer);
创建线程函数 TThreadClass = TPoolThread
并设置OnThreadBegin OnThreadEnd 事件处理函数 添加到FThreadList(TPoolThread)
InterlockedIncrement原子操作计任务数量
DeleteMandatory删除指定任务
StopAllThread停止所有任务
ClearAllThread 清除
FindThread 查找
GetThreadItem 按index 查找
CreateNewThread 执行TPoolThread .create
TThreadPool.SetManageThread(ThreadClass: TThreadClass); 设置 此函数作用不明
TPoolThread 管理线程自身 确切的说是线程池就是管理此类
此类设计比较蛋疼 本应该是个独立的管理类负责管理 线程的挂起 运行
却又写个了run虚函数 实在是不解
本应把API丢给 TThreadPool 创建
正确的做法是 设计 ThreadManager
TPoolThread简化成结构体 包含ThreadManager task 线程锁 标志
然后用一个数组或者链表维护 具体的任务交由task的run函数去执行
thread_proc 里去执行task.run
TWorkQueue 工作队列 TThreadPool.AddWork添加到此队列中
父类TQueue 实现简单的链表功能
同单元的TStack类 预分配一块内存 模拟了栈的快速的寻址 缺点空间太小
同单元的TList 实现使用内存管理
TVector 容器 简单管理
带有APC 的是作者简单线程池实现
BaseThreadProc task.run类似
TBaseThread更像我说的 ThreadManager 包含线程策略
TInterfacePoolThread 继承自TPoolThread
IThreadRun run接口 APC的
总结两种线程池结合 完美
补充
具体的类结构图
TThreadPool 线程池基类 没有派生类
TBaseThread 虚基类 用户线程从此派生 托管了一个 IBaseThread = interface
TPoolThread 虚基类 派生类 TInterfacePoolThread(托管一个 IPoolThread = interface)
TBaseThread(用户类) TPoolThread)(池任务) 两者在内存池中进行关联
FThreadClass := TInterfacePoolThrea
TAPC开头的未使用
发表评论