Lengend线程分析_1234FCOM专注游戏工具及源码例子分享

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开头的未使用