Delphi中的线程类
猛禽[Estudio mental]
http://mental.mentsu.com
之五(大结局)
回到前面CheckSynchronize,见下面的代码:
función CheckSynchronize(Tiempo de espera: entero = 0): booleano;
var
Sincronización: PSyncProc;
Lista de sincronización local: Lista T;
comenzar
si GetCurrentThreadID <> MainThreadID entonces
elevar EThread.CreateResFmt(@SCheckSynchronizeError, [GetCurrentThreadID]);
si el tiempo de espera > 0 entonces
WaitForSyncEvent (tiempo de espera)
demás
ReiniciarSyncEvent;
LocalSyncList := nulo;
EnterCriticalSection(ThreadLock);
intentar
Entero (LocalSyncList): = InterlockedExchange (Entero (SyncList), Entero (LocalSyncList));
intentar
Resultado := (LocalSyncList <> nulo) y (LocalSyncList.Count > 0);
si resultado entonces
comenzar
mientras que LocalSyncList.Count> 0 lo hace
comenzar
SyncProc := LocalSyncList[0];
LocalSyncList.Delete(0);
LeaveCriticalSection(ThreadLock);
intentar
intentar
SyncProc.SyncRec.FMétodo;
excepto
SyncProc.SyncRec.FSynchronizeException := AcquireExceptionObject;
fin;
finalmente
EnterCriticalSection(ThreadLock);
fin;
SetEvent(SyncProc.señal);
fin;
fin;
finalmente
LocalSyncList.Gratis;
fin;
finalmente
LeaveCriticalSection(ThreadLock);
fin;
fin;
首先,这个方法必须在主线程中被调用(如前面通过消息传递到主线程),否则就抛出异常.
接下来调用ResetSyncEvent(它与前面SetSyncEvent对应的,之所以不考虑WaitForSyncEvent的情况,是因为只有在linux版下才会调用带参数的CheckSynchronize,Windows版下都是调用默认参数0的CheckSynchronize)。
现在可以看出SyncList的用途了:它是用于记录所有未被执行的同步方法的。因为主线程只有一个,而子线程可能有很多个,当多个子线程同时调用同步方法时,主线程可能一时无法处理,所以需要一个列表来记录它们.
在这里用一个局部变量LocalSyncList来交换SyncList,这里用的也是一个原语:I nterlockedExchange。同样,这里也是用临界区将对SyncList的访问保护起来。
只要LocalSyncList不为空,则通过一个循环来依次处理累积的所有同步方法调用。最后把处理完的LocalSyncList释放掉,退出临界区.
第一个同步方法调用数据。然后退出临界区(原因当然也是为了防止死锁)。
接着就是真正的调用同步方法了.
如果同步方法中出现异常,将被捕获后存入同步方法数据记录中。
重新进入临界区后,调用SetEvent通知调用线程,同步方法执行完成了(详见前面Synchronize中的WaitForSingleObject调用).
至此,整个Synchronize的实现介绍完成。
最后来说一下WaitFor,它的功能就是等待线程执行结束。其代码如下:
función TThread.WaitFor: LongWord;
var
H: matriz[0..1] de THandle;
EsperaResultado: Cardenal;
Mensaje: Mensaje de MT;
comenzar
H[0] := FMango;
si GetCurrentThreadID = MainThreadID entonces
comenzar
Resultado de espera: = 0;
H[1] := Evento de sincronización;
repetir
{ Esto evita un posible punto muerto si el hilo en segundo plano
hace un SendMessage al hilo de primer plano}
si WaitResult = WAIT_OBJECT_0 + 2 entonces
PeekMessage(Mensaje, 0, 0, 0, PM_NOREMOVE);
WaitResult := MsgWaitForMultipleObjects(2, H, Falso, 1000, QS_SENDMESSAGE);
CheckThreadError(Resultado de espera <> WAIT_FAILED);
si WaitResult = WAIT_OBJECT_0 + 1 entonces
ComprobarSincronizar;
hasta WaitResult = WAIT_OBJECT_0;
fin más WaitForSingleObject(H[0], INFINITO);
CheckThreadError(GetExitCodeThread(H[0], Resultado));
fin;
如果不是在主线程中执行WaitFor的话,很简单,只要调用WaitForSingleObject等待此线程的Handle为Signaled状态即可.
如果是在主线程中执行WaitFor则比较麻烦。首先要在Mano le 数组中增加一个SyncEvent,然后循环等待,直到线程结Haga clic en MsgWaitForMultipleObjects para WAIT_OBJECT_0, use MSDN para usar API的说明).
在循环等待中作如下处理:如果有消息发生,则通过PeekMes salvia取出此消息(但并不把它从消息循环中移除),然后调用M sgWaitForMultipleObjects来等待线程Handle或SyncEvent出现Signaled状态,同时监Han dle的WaitForSingleObject。如果是SyncEvent被SetEvent(返回WAIT_OBJECT_0 + 1),则调用CheckSynchronize处理同步方法。
为什么在主线程中调用WaitFor必须用MsgWaitForMultipleObjects,而不能用WaitForSingleObject等待线程结束呢?因为防止死锁。由于在线程函数Execute中可能调用Sincronizar处理同步方法,而同步方法是在主线程中执行的,如果用WaitForSin gleObject等待的话,则主线程在这里被挂起,同步方法无法执行,导致线程也被挂起,于是发生死锁。
而改用WaitForMultipleObjects则没有这个问题。首先,它的第三个参数为False,表示只要线程Handle或SyncEvent中只要有一个Signaled即可使主线程被唤醒,至于加上QS_SEND MENSAJESincronizar用Sincronizar时,主线程就会被唤醒并处理同步调用,在调用完成后继续进入挂起等待状态,直到线程结束.
至此,对线程类TThread的分析可以告一个段落了,对前面的分析作一个总结:
1 、线程类的线程必须按正常的方式结束,即Ejecutar执行结束,所以在其中的代码中必须在适当的地方加入足够多的对T erminate标志的判断,并及时退出。如果必须要“立即”退出,则不能使用线程类,而要改用API或RTL函数。
2、 对可视VCL的访问要放在Synchronize中,通过消息传递到主线程中,由主线程处理。
3、 线程共享数据的访问应该用临界区进行保护(当然用Synchronize也行)。
4、 线程通信可以采用Event进行(当然也可以用Suspender/Reanudar)。
5、 当在多线程应用中使用多种线程同步方式时,一定要小心防止出现死锁。
6、 等待线程结束要用WaitFor方法.
Dic.01-03
(终于续完了)