Delphi中的线程类
猛禽[จิตสตูดิโอ]
http://mental.mentu.com
之五 (大结局)
回到前 FaceCheckSynchronize，见下的代码：
ฟังก์ชั่น CheckSynchronize (หมดเวลา: จำนวนเต็ม = 0): บูลีน;
var
SyncPRoc: PSyncProc;
LocalSyncList: TList;
เริ่ม
ถ้า GetCurrentThreadID <> MainThreadID แล้ว
เพิ่ม EThread.CreateResFmt(@SCheckSynchronizeError, [GetCurrentThreadID]);
ถ้าหมดเวลา> 0 แล้ว
WaitForSyncEvent (หมดเวลา)
อื่น
รีเซ็ตเหตุการณ์ซิงค์;
LocalSyncList := ไม่มี;
EnterCriticalSection(ThreadLock);
พยายาม
จำนวนเต็ม(LocalSyncList) := InterlockedExchange(จำนวนเต็ม(SyncList), จำนวนเต็ม(LocalSyncList));
พยายาม
ผลลัพธ์ := (LocalSyncList <> ไม่มี) และ (LocalSyncList.Count > 0);
ถ้าผลลัพธ์แล้ว
เริ่ม
ในขณะที่ LocalSyncList.Count > 0 ทำ
เริ่ม
SyncProc := LocalSyncList[0];
LocalSyncList.Delete(0);
LeaveCriticalSection (ThreadLock);
พยายาม
พยายาม
SyncProc.SyncRec.FMethod;
ยกเว้น
SyncProc.SyncRec.FSynchronizeException := AcquireExceptionObject;
จบ;
ในที่สุด
EnterCriticalSection(ThreadLock);
จบ;
SetEvent(SyncProc.signal);
จบ;
จบ;
ในที่สุด
LocalSyncList ฟรี;
จบ;
ในที่สุด
LeaveCriticalSection (ThreadLock);
จบ;
จบ;
首先，这个方法必须在主线程中被调用（如前的通过消息传递到主线程），否则就抛出异常。
接下来调用ResetSyncEvent（它与前เลดี้SetSyncEvent对应的，之所以不考虑WaitForSyncEvent ของ情况，是因为只มีอยู่ใน linux 版下才会调用带参数ของ CheckSynchronize, Windows版下都是调用默认参数0 ของ CheckSynchronize).
现在可以看出SyncList的用途了：它是用于记录所有未被执行的同步方法的。因为主线程只มี一个,而子线程可能有很多个，当多个子线程同时调用同步方法时，主线程可能一时无法处理，所以需要一个列表来记录它们。
อยู่ที่这里用一个局部变量LocalSyncList来交换SyncList，这里用的也是一个原语：I nterlockedExchange。同样，这里也是用临界区将对SyncList的访问保护起来。
只要LocalSyncList不为空，则通过一个循环来依次处理累积的所有同步方法调用。最后把处理完的LocalSyncList释放掉，退出临界区。
再来看对同步方法的处理：首先是从列表中移出（取出并从列表中删除）第一个同步方法调用数据。然后退出临界区（原因当然也是为了防止死锁）。
接着就是真正的调用同步方法了。
如果同步方法中出现异常,将被捕获后存入同步方法数据记录中。
重新进入临界区后，调用SetEvent通知调用线程，同步方法执行完成了（详见前 FaceSynchronize中的WaitForSingleObject调用）。
至此，整个Synchronize的实现介绍完成。
最后来说一下WaitFor，它的功能就是等待线程执行结束。其代码如下：
ฟังก์ชั่น TThread.WaitFor: LongWord;
var
H: อาร์เรย์ [0..1] ของ THandle;
WaitResult: พระคาร์ดินัล;
ข่าวสารเกี่ยวกับ: TMsg;
เริ่ม
H[0] := Fแฮนเดิล;
ถ้า GetCurrentThreadID = MainThreadID แล้ว
เริ่ม
รอผลลัพธ์ := 0;
H[1] := SyncEvent;
ทำซ้ำ
{ วิธีนี้จะป้องกันการหยุดชะงักที่อาจเกิดขึ้นหากเธรดพื้นหลัง
ส่ง SendMessage ไปยังเธรดเบื้องหน้า }
ถ้า WaitResult = WAIT_OBJECT_0 + 2 แล้ว
PeekMessage (ข่าวสารเกี่ยวกับ 0, 0, 0, PM_NOREMOVE);
WaitResult := MsgWaitForMultipleObjects (2, H, False, 1,000, QS_SENDMESSAGE);
CheckThreadError (ผลลัพธ์รอ <> WAIT_FAILED);
ถ้า WaitResult = WAIT_OBJECT_0 + 1 แล้ว
ตรวจสอบซิงโครไนซ์;
จนกระทั่ง WaitResult = WAIT_OBJECT_0;
จบอย่างอื่น WaitForSingleObject(H[0], INFINITE);
CheckThreadError(GetExitCodeThread(H[0], ผลลัพธ์));
จบ;
如果不是在主线程中执行WaitFor的话,很简单，只要调用WaitForSingleObject等待此线程的Handle为Signaled状态即可。
如果是在主线程中执行WaitFor则比较麻烦。首先要在Handle数组中增加一个SyncEvent，然后循环等待，直到线程结束(即MsgWaitForMultipleObjectsWAIT_OBJECT_0,详见MSDN中关于此API ของ 说明).
在循环等待中作如下处理：如果有消息发生，则通过PeekMes ปราชญ์取出此消息（但并不把它从消息循环中移除），然后调用M sgWaitForMultipleObjects来等待线程Handle或SyncEvent出现Signaled状态,同时监听消息（QS_SENDMESSAGE参数，详见MSDN中关于此API的说明）。可以把此API当作一个可以同时等待多个Han dle ของ WaitForSingleObject 如果是SyncEvent 被SetEvent (返回WAIT_OBJECT_0 + 1) เช็คซิงโครไนซ์ 处理同步方法。
为什么在主线程中调用WaitFor必须用MsgWaitForMultipleObjects,而不能用WaitForSingleObject等待线程结束呢？因为防止死锁。由于在线程函数Execute中可能调用Synchronize处理同步方法，而同步方法是在主线程中执行的，如果用WaitForSin gleObject等待的话，则主线程在这里被挂起，同步方法无法执行，导致线程也被挂起，于是发生死锁。
而改用WaitForMultipleObjects则没有这个问题。首先，它的第三个参数为False，表示只要线程Handle或SyncEvent中只要有一个Signaled即可使主线程被唤醒,至于加上QS_SEND ข้อความ是因为ซิงโครไนซ์是通过消息传到主线程来的，所以还要防止消息被阻塞。这样，当线程中调用ซิงโครไนซ์时，主线程就会被唤醒并处理同步调用，在调用完成后继续进入挂起等待状态，直到线程结束。
至此，对线程类TThread的分析可以告一个段落了，对前的分析作一个总结：
1、线程类的线程必须按正常的方式结束，即Execute执行结束，所以在其中的代码中必须在适当的地方加入足够多的对T erminated标志的判断，并及时退出。如果必须要“立即”退出，则不能使用线程类，而要改用API或RTL函数。
2、 对可视VCL的访问要放在Synchronize中，通过消息传递到主线程中，由主线程处理。
3、 线程共享数据的访问应该用临界区进行保护（当然用Synchronize也行）。
4、 线程通信可以采用กิจกรรม 进行（当然也可以用Suspend/Resume）。
5、 当在多线程应用中使用多种线程同步方式时，一定要小heart防止出现死锁。
6、 等待线程结束要用รอก่อน方法。
ธ.ค.01-03
（终于续完了）