创建线程池实验

王朝other·作者佚名  2006-10-26
窄屏简体版  字體: |||超大  

前几天,在工作线程完成任务后,通过在工作线程内执行 Suspend 将工作线程休眠,然后管理线程轮询线程池中的工作线程是否 Suspended 是否 = TRUE 要判断工作线程是否空闲。

但结果发现, 工作线程执行 Suspend 后,常常 Suspended = FALSE,搞得线程池中的工作线程全部假死。

只有另寻方法:用 Event 或 Mutex 通过去 WaitforSingleObejct 来实现工作线程休眠等待。

思路如下:

1. 在管理线程中为每个工作线程创建各自的Mutex,

2. 在工作线程完成工作后将 Mutex 置为无信号。

并且 WaitForSingleObject(hMutex,INFINITE) 进入等待状态。

3. 管理线程在有任务时,查询各线程的 Mutex, 看看如果是无信号(表示正在休眠),马上分配任务给这个线程,并将属于这个线程的 Mutex 置为有信号,让它马上进入工作。

不知是否可行。

另外

在《Delphi 5 开发人员指南》中说到

引用:

提示 临界区与事件对象(比如互斥对象)的最大的区别是在性能上。临界区在没有线程冲突时,要用1 0 ~ 1 5个时间片,而事件对象由于涉及到系统内核要用400~600个时间片。

看了一早上的资料,发现只能用 Event 对像。

因为一个Thread已取得Mutex的所有权,而它呼叫WaitForSingleObject() n 次,则也要使用ReleaseMutex n次才能够将Mutex的拥有权放弃,而且,非Mutex拥有者呼叫ReleaseMutex也不会有任何作用。

destructor TThreadManager.Destroy;

begin

Self.Terminate;

inherited;

end;

procedure TThreadManager.Execute;

var

n: Int64;

begin

FreeOnTerminate := True;

while not Terminated do

begin

Sleep(50);

Inc(n);

end;

end;

{中断线程}

procedure TfrmMainForm.btnStopClick(Sender: TObject);

begin

{1 如果线程中有 FreeOnTerminate := True; 用

ThreadManager.Terminate;

*注: Terminate 并不直接终止线程, 只是将线程的 Terminated 置为 TRUE

}

{2. 如果线程中无 FreeOnTerminate := True; 且

destructor TThreadManager.Destroy;

begin

Self.Terminate;

inherited;

end;

用 FreeAndNil(ThreadManager);}

end;

FEvent: THandle;

FEvent := Windows.CreateEvent( nil,false, false, nil );

各参数的意义如下:

◇ 参数一:填上 nil 即可。

◇ 参数二:是否采用手动调整灯号。

◇ 参数三:灯号的起始状态,False 表示绿灯灭。

◇ 参数四:Event 名称, 对象名称相同的话,会指向同一个对

象,所以想要有两个Event对象,便要有两个不同的名称(这名

称以字符串来存.为NIL的话系统每次会自己创建一个不同的名字,就是被次创建的都是新的EVENT)。

◇ 传回值:Event handle。

实现: 在没任务时就阻塞工人线程, 不占用CPU资源, 有任务时绿灯唤醒:

池中的工人线程

代码:

procedure TThreadWorker.Execute;

var

mTask: PTask;

begin

while not Terminated do

begin

//一直休眠到 FEvent 被管理者线程亮灯为止....

if FEvent > 0 then

WaitForSingleObject(FEvent, INFINITE);

//在管理线程中取任务

FGetTask(mTask);

//如果有任务

if Assigned(mTask) then

begin

//处理任务....

//DoSomething;

mTask^.FCMD := '线程[' + IntToStr(FID) + ']任务:' + mTask^.FCMD;

//将处理结果回写

FAnswer(mTask);

end;

end;

end;

管理者类:

代码:

procedure TThreadManager.ManageTask(const AOption: TTaskOption;

var VTask: PTask);

begin

//进入临界区同步

EnterCriticalSection(MANAGE_TASK_CS);

try

case AOption of

eoRead: //取任务

begin

//如有任务, 取任务

if FTaskPool.Count > 0 then

begin

VTask := PTask(FTaskPool[0]);

FTaskPool.Delete(0);

end

else

VTask := nil;

//如没任务, 转红灯, 让工人们休息一会.

if FTaskPool.Count = 0 then

ResetEvent(FEvent);

end;

eoWrite: //添加任务

begin

FTaskPool.Add(VTask);

VTask := nil;

//亮绿灯, 唤醒工人, 周扒皮一下.

SetEvent(FEvent);

end;

end; {case}

finally

{ [修改者:谁变]try..finally保护,防卡线程进入监界面出现异常,

无法执行离开监界区命令 }

LeaveCriticalSection(MANAGE_TASK_CS);

end;

end;

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航