Lengend线程分析

2020-04-23 11:21:28  阅读 50 次 评论 0 条

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


本文地址:http://www.uc845.com/post/734.html
版权声明:本文为原创文章,版权归 游戏伴随我 所有,欢迎分享本文,转载请保留出处!

发表评论


表情

还没有留言,还不快点抢沙发?