DLL ActiveForm 线程同步问题

本文试着从分析Synchronize同步执行的实现机制入手,来解决DLL/ActiveForm中线程同步的问题。
  线程中进行同步时调用的Synchronize函数,仅仅是把调用调用线程、调用方法地址、异常对象封装在一个同步结构中,然后调用处理同步结构的类方法Synchronize。
  procedure TThread.Synchronize(Method: TThreadMethod);
  begin
   FSynchronize.FThread := Self;
   FSynchronize.FSynchronizeException := nil;
   FSynchronize.FMethod := Method;
   Synchronize(@FSynchronize);
  end;
  
  class procedure TThread.Synchronize(ASyncRec: PSynchronizeRecord);
  var
   SyncProc: TSyncProc;
  begin
   if GetCurrentThreadID = MainThreadID then // 如果是主线程,当然也就不需要同步处理了,直接执行即可
   ASyncRec.FMethod
   else
   begin
   SyncProc.Signal := CreateEvent(nil, True, False, nil); // 创建一个未命名事件,用于主线程执行同步的过程结束时通知等待线程
   try
   EnterCriticalSection(ThreadLock); // 进入ThreadLock关键区,用于保护对Classes单元的全局变量SyncList的访问和进行一些调用的同步
   try
   if SyncList = nil then
   SyncList := TList.Create;
   SyncProc.SyncRec := ASyncRec;
   SyncList.Add(@SyncProc); // 把要同步的结构添加到列表SyncList中,等待主线程取出执行同步过程代码
   SignalSyncEvent; // 调用SetEvent(SyncEvent)使同步事件SyncEvent处于信号状态,主要用在正确处理线程结束时
   if Assigned(WakeMainThread) then
   WakeMainThread(SyncProc.SyncRec.FThread); // 关键!Classes.WakeMainThread就是Application.WakeMainThread,通过PostMessage发个WM_NULL空消息,让主线程醒来
   LeaveCriticalSection(ThreadLock); // 离开关键区,因为主线程调用的过程CheckSynchronize中会在取出SyncList列表同步结构前先进入关键区的
   try
   WaitForSingleObject(SyncProc.Signal, INFINITE); // 等待主线程同步调用结束通知事件
   finally
   EnterCriticalSection(ThreadLock);
   end;
   finally
   LeaveCriticalSection(ThreadLock);
   end;
   finally
   CloseHandle(SyncProc.Signal);
   end;
   if Assigned(ASyncRec.FSynchronizeException) then raise ASyncRec.FSynchronizeException;
   end;
  end;
  在主线程的消息处理过程WndProc中检索到WM_NULL消息就会调用CheckSynchronize对同步列表SyncList中的同步结构进行逐个处理,直至SyncList中要同步的方法全部被同步调用完毕。而在应用程序空闲时也会调用CheckSynchronize进行同步处理。
  procedure TApplication.WndProc(var Message: TMessage);
  begin
   try
   (略)
   with Message do
   case Msg of
   WM_NULL:
   CheckSynchronize;
   else
   Default;
   end;
   except
   HandleException(Self);
   end;
  end;
  procedure TApplication.Idle(const Msg: TMsg);
  begin
   (略)
   if (GetCurrentThreadID = MainThreadID) and CheckSynchronize then
   Done := False;
   if Done then WaitMessage;
  end; 
  再看一下Delphi封装的实际线程执行体函数:
  function ThreadProc(Thread: TThread): Integer;
  var
   FreeThread: Boolean;
  begin
   try
   if not Thread.Terminated then
   try
   Thread.Execute;
   except
   Thread.FFatalException := AcquireExceptionObject;
   end;
   finally
   FreeThread := Thread.FFreeOnTerminate; // 是否线程执行结束后自动释放Thread对象实例?
   Result := Thread.FReturnValue;
   Thread.DoTerminate; // 这里调用Synchronize(CallOnTerminate),也就是说OnTerminate事件代码实际上是在主线程中同步执行的
   Thread.FFinished := True;
   SignalSyncEvent; // 使同步事件SyncEvent处于信号状态,使线程Destory调用WaitFor时如果是主线程,可以进行必要的同步处理
   if FreeThread then Thread.Free; // 注意:线程Destroy部分的代码是在线程执行体中执行的
   EndThread(Result);
   end;
  end;
  
  到这里我们基本清楚了Synchronize同步的实现机制:
  线程将同步线程、方法封装成同步结构,添加到同步列表SyncList中,然后发送WM_NULL消息唤醒主线程,然后调用WaitForSingleObject挂起等待主线程处理。主线程处理WM_NULL消息或在空闲时调用CheckSynchronize,从同步列表SyncList取出同步结构,在主线程中调用执行同步方法,执行完毕通过同步结构中的未命名事件句柄通知等待线程。等待线程收到事件通知后醒来,然后继续执行。
  
  以上是对通常的应用程序中的线程Synchronize同步实现机制的分析,而对于DLL中的线程在用Synchronize进行同步时又有它的特殊性。
  DLL中的全局变量是每个DLL都复制一份的,各个DLL之间以及DLL与主程序之间不能直接进行数据共享。这也就是说主程序的SyncEvent、SyncList、ThreadLock与DLL中的SyncEvent、SyncList、ThreadLock变量是不一样的。因此在DLL中的Synchronize同步,使用到的是DLL中的SyncEvent、SyncList、ThreadLock等变量,因此,直接使用Synchronize,主程序的CheckSynchronize就无法对DLL中的线程进行同步调度执行。而DLL中的Application却从来没有运行Run进入消息循环,因此也不能调用CheckSynchronize来处理线程的同步。因此在DLL中就需要主动调用CheckSynchronize函数来对同步列表SyncList进行处理。可以在DLL中专门创建一个窗口,在窗口消息循环中处理WM_NULL消息,调用ChechSynchronize即可。
  while PeekMessage(Msg, 0, 0, 0, PM_REMOVE) do
   if Msg.message = WM_NULL then
   CheckSynchronize
   else
   begin
   TranslateMessage(Msg);
   DispatchMessage(Msg);
   end;
  
  对ActiveForm中使用的线程调用Synchronize的情况也大体上相同,它的宿主进程是浏览器(如IE),IE一来不是Delphi编的程序,不会在主程序消息循环主调用CheckSynchronize进行同步处理的;二来即使它进行同步处理,也不是采用Delphi的同步实现方法,没有SyncList、SyncEvent、ThreadLock等变量的使用的;另外,ActiveForm由于是个OCX(实际上是种DLL),因此还有如同上述DLL中线程同步的问题,解决办法也可以和上面一样。当然,应该也可以直接在ActiveForm中添加处理WM_NULL消息的处理过程,调用CheckSynchronize进行同步处理,我没有进行试验,具体地,你可以亲自试一下。

参考:http://m.blog.csdn.net/blog/fghydx/18699709

时间: 2024-08-28 13:23:51

DLL ActiveForm 线程同步问题的相关文章

进程/线程同步的方式和机制,进程间通信

转自: http://www.cnblogs.com/memewry/archive/2012/08/22/2651696.html 一.进程/线程间同步机制. 临界区.互斥区.事件.信号量四种方式临界区(Critical Section).互斥量(Mutex).信号量(Semaphore).事件(Event)的区别1.临界区:通过对多线程的串行化来访问公共资源或一段代码,速度快,适合控制数据访问.在任意时刻只允许一个线程对共享资源进行访问,如果有多个线程试图访问公共资源,那么在有一个线程进入后

.NET中的异步操作及线程同步

执行异步操作 CLR使用了WIN的线程处理能力,但保留了与其分离的权利.某些时候CLR的线程与Win的线程不是完全的匹配. 线程的系统开销较大,应限制其数量. 创建:分配并初始化一线程内核对象,保留1M的地址空间(用户模式),12KB的堆栈(内核模式),然后调用DLL函数通知进程中所有DLL操作来通知所有DLL操作又有一新的线程了. 销毁:进程中所有DLL收到一个死亡通知,且释放资源.且当仅有一个CPU时,每隔20ms执行一次上下文切换. CLR线程池. 每个进程一个,被该进程内的所有APP域共

MFC——9.多线程与线程同步

Lesson9:多线程与线程同步 程序.进程和线程是操作系统的重点,在计算机编程中,多线程技术是提高程序性能的重要手段.本文主要讲解操作系统中程序.进程和线程之间的关系,并通过互斥对象和事件对象实例说明多线程和线程同步技术. 1.      程序.进程和线程 1.1  程序和进程 程序是计算机指令的集合,它以文件的形式存储在磁盘上.进程通常被定义为一个正在运行的程序的实例,是一个程序在其自身的地址空间中的一次执行活动.进程是资源申请.调度和独立运行的单位,因此,它使用系统中的运行资源:而程序不能

进程的同步与通信,进程与线程同步的区别,进程与线程通信的区别【转】

本文转载自:http://www.cnblogs.com/youngforever/p/3250270.html 这两天看进程的同步与通信,看了几本书上的介绍,也从网上搜了很多资料,越看越迷惑,被这几个问题搞得很纠结. 进程同步与互斥的区别? 进程的同步方式有哪些? 进程的通信方式有哪些? 进程同步与通信的区别是什么? 线程的同步/通信与进程的同步/通信有区别吗? 在好多教材上(包括国内与国外的)也没有明确这些概念,现在对每个问题还没有准确的答案,下面将自己的理解记下来,以后再补充. 参考资料:

[.net]基元线程同步构造

1 /* 基元线程同步构造 2 用户模式构造: 3 易变构造(Volatile Construct) 4 互锁构造(Interlocked Construct):自旋锁(Spinlock) 乐观锁(Optimistic Concurrency Control,乐观并发控制) 5 内核模式构造: 6 事件构造(Event) 7 信号量构造(Semaphore) 8 互斥体构造(Mutex) 9 */ 10 11 //易变构造,Volatile.Write()之前的所有字段写入操作,必须再该方法调用

iOS多线程编程:线程同步总结 NSCondtion

1:原子操作 - OSAtomic系列函数 iOS平台下的原子操作函数都以OSAtomic开头,使用时需要包含头文件<libkern/OSBase.h>.不同线程如果通过原子操作函数对同一变量进行操作,可以保证一个线程的操作不会影响到其他线程内对此变量的操作,因为这些操作都是原子式的.因为原子操作只能对内置类型进行操作,所以原子操作能够同步的线程只能位于同一个进程的地址空间内. 2:锁 - NSLock系列对象 iOS平台下的锁对象为NSLock对象,进入锁通过调用lock函数,解锁调用unl

线程同步之EVENT

事件可传信给其他线程,表示某些条件现在已具备,比如有可用的消息. 事件可分为手动复位和自动复位,前者可传信给许多同时等待事件的线程而且可以被复位. 自动复位的事件传信给单个等待时间的线程,该事件会自动复位. Applications can use event objects in a number of situations to notify a waiting thread of the occurrence of an event. For example, overlapped I/O

【java并发】(2) Java线程同步:synchronized锁住的是代码还是对象

在Java中,synchronized关键字是用来控制线程同步的,就是在多线程的环境下,控制synchronized代码段不被多个线程同时执行.synchronized既可以加在一段代码上,也可以加在方法上. 关键是,不要认为给方法或者代码段加上synchronized就万事大吉,看下面一段代码: class Sync { public synchronized void test() { System.out.println("test开始.."); try { Thread.sle

Java多线程(二) —— 线程安全、线程同步、线程间通信(含面试题集)

一.线程安全 多个线程在执行同一段代码的时候,每次的执行结果和单线程执行的结果都是一样的,不存在执行结果的二义性,就可以称作是线程安全的. 讲到线程安全问题,其实是指多线程环境下对共享资源的访问可能会引起此共享资源的不一致性.因此,为避免线程安全问题,应该避免多线程环境下对此共享资源的并发访问. 线程安全问题多是由全局变量和静态变量引起的,当多个线程对共享数据只执行读操作,不执行写操作时,一般是线程安全的:当多个线程都执行写操作时,需要考虑线程同步来解决线程安全问题. 二.线程同步(synchr