BCB 多线程的同步与协调
多线程编程是提高系统资源利用率的一种常见方式。它占用的资源更小,启动更快,还可以实现在后台运行一些需时较长的操作。[喝小酒的网摘]http://blog.hehehehehe.cn/a/8498.htm 一、初识TThread对象VCL提供了用于多线程编程的TThread类,在这个类中封装了Windows关于线程机制的Windows API,通常将它的实例成为线程对象。线程对象通过封装简化了多线程应用程序的编写。注意,线程对象不允许控制线程堆栈的大小或安全属性。若需要控制这 些,必须使用Windows API的CreateThread()或BeginThread()函数。不过,即使是使用Windows Thread API函数建立和控制多线程,仍然可从一些同步线程对象或下节将要描述的方法中受益。要在应用程序中使用线程对象,必须创建TThread的一个派生类。File|New|Thread Object,系统会提示为新线程对象提供类名,我们将其命名为TMyThread。我们必须自行在构造函数以及Execute()函数中添加代码。自动 生成的构造函数中有一个参数,如果为true的话线程创建后将进入挂起状态,直到线程对象的Resume()函数被调用才开始执行。如果为false则线 程创建后会立刻开始执行。我们先创建一个实例来亲自感受下多线程:在窗体上放两个Button和两个Edit组件,自动命名。然后File|New|Thread Object来创建一个线程对象,命名为TMyThread。以下请看完整工程代码: //Unit1.h //主窗体头文件//--------------------------------------------------------------------------- #ifndef Unit1H #define Unit1H //--------------------------------------------------------------------------- #include <Classes.hpp> #include <Controls.hpp> #include <StdCtrls.hpp> #include <Forms.hpp> #include "Unit2.h" //--------------------------------------------------------------------------- class TForm1 : public TForm { __published: // IDE-managed Components TButton *Button1; TButton *Button2; TEdit *Edit1; TEdit *Edit2; void __fastcall Button1Click(TObject *Sender); void __fastcall Button2Click(TObject *Sender); void __fastcall FormCreate(TObject *Sender); private: // User declarations TMyThread *thread1,*thread2; public: // User declarations __fastcall TForm1(TComponent* Owner); }; //--------------------------------------------------------------------------- extern PACKAGE TForm1 *Form1; //--------------------------------------------------------------------------- #endif//Unit1.cpp //主窗体实现文件//--------------------------------------------------------------------------- #include <vcl.h> #pragma hdrstop#include "Unit1.h" //--------------------------------------------------------------------------- #pragma package(smart_init) #pragma resource "*.dfm" TForm1 *Form1; //--------------------------------------------------------------------------- __fastcall TForm1::TForm1(TComponent* Owner) : TForm(Owner) { } //--------------------------------------------------------------------------- void __fastcall TForm1::Button1Click(TObject *Sender) { thread1->Resume(); //单击后才启动线程 } //--------------------------------------------------------------------------- void __fastcall TForm1::Button2Click(TObject *Sender) { thread2->Resume(); } //--------------------------------------------------------------------------- void __fastcall TForm1::FormCreate(TObject *Sender) { thread1=new TMyThread(true,Edit1); //创建线程对象实例 thread2=new TMyThread(true,Edit2); } //---------------------------------------------------------------------------//Unit2.h //线程类头文件//--------------------------------------------------------------------------- #ifndef Unit2H #define Unit2H //--------------------------------------------------------------------------- #include <Classes.hpp> //--------------------------------------------------------------------------- class TMyThread : public TThread { private: TEdit *edResult; //自定义局部变量 String strResult; protected: void __fastcall Execute(); void __fastcall ShowResult(); //自定义函数 public: __fastcall TMyThread(bool CreateSuspended,TEdit *AEdit); //注意:修改了默认参数 }; //--------------------------------------------------------------------------- #endif//Unit2.cpp //线程类实现文件//--------------------------------------------------------------------------- #include <vcl.h> #pragma hdrstop#include "Unit2.h" #pragma package(smart_init) //--------------------------------------------------------------------------- __fastcall TMyThread::TMyThread(bool CreateSuspended,TEdit *AEdit) : TThread(CreateSuspended) { edResult=AEdit; } //--------------------------------------------------------------------------- void __fastcall TMyThread::Execute() { for(int i=0;i<200;i++) { strResult=IntToStr(i); Synchronize(ShowResult); //管理线程同步,保证安全性 Sleep(100); } } //--------------------------------------------------------------------------- void __fastcall TMyThread::ShowResult() { edResult->Text=strResult; } //--------------------------------------------------------------------------- 然后我们F9运行程序就可以查看效果了。二、编写线程函数Execute()函数就是线程函数,它包含了程序中所有需要并行执行的代码。除了共享相同的进程空间外,可以认为线程就是通过应用程序启动的程序。但在 编写线程函数的时候需要注意与单独程序的不同之处。因为线程与其他线程共享内存空间,所以必须确认没有覆盖应用程序中其它线程的内存地址。而另一方面,可 以使用共享内存在线程之间进行通信。在线程函数内部,我们可以使用任意的全局变量,但有些变量我们并不希望同一线程类的其他实例共享它,就可以声明一个线程(thread-local)变 量。通过将__thread修饰语加入变量声明就可以声明一个线程变量。例如 int __thread x; 声明一个整型变量。__thread修饰语只可用于全局(文件范围)或静态变量。指针和函数变量不能作为线程变量。使用“在写入时复制”语法的类,如AnsiStrings也不能作为线程变量。需要在运行时进行初始化或析构的类型也不能被声明为__thread类型。当程序中调用Resume()函数时,线程启动并继续执行直到Execute()结束。这就是线程执行特定任务,并在其完成时终止的模式。然而,有时应用 程序需在一些外部条件满足时终止线程。通过检查Terminated属性可允许其它线程通知本线程终止。当其它线程试图终止本线程时,它调用 Terminate()函数。Terminate()函数将本线程的Terminated属性设置为true。Execute()函数通过检查和响应 Terminated属性来实现Terminate()函数。下面的实例演示了这种做法: void __fastcall TMyThread::Execute() { while( !Terminated ) { } }在线程函数终止时我们可能需要做一些清理工作。由于在线程终止前,OnTerminate事件会发生,所以我们可以将清理代码放在OnTerminate 事件处理程序中,这样可确保不管Execute()函数如何执行,清理代码总是可以被执行。要注意OnTerminate事件处理程序不作为线程的一部分 运行,而是在应用程序的主线程中执行的。这意味着: (1)在OnTerminate事件处理程序中不能使用任何线程局部变量。 (2)在OnTerminate事件处理程序中可安全地访问任何组件及VCL对象而不会和其他线程发生冲突。三、协调线程在编写线程执行时运行的代码时,必须考虑到可能同步执行的其他线程行为。主要有两种情况:一个是避免两个线程试图同时使用某一个全局对象或变量;另一个是某线程中的一些代码可能会依赖其他线程所执行任务的结果。1,避免同时访问 为避免在访问全局对象或变量时与其他线程发生冲突,可能需要暂停其他线程的执行,直到该线程代码完成操作。这里需要注意,不要暂停其他不需停止的线程执行,这样会使效率严重降低,也无法获得使用多线程的优点。<1>,锁定对象 一些对象内置了锁定功能,以防止其他线程使用该对象的实例。例如,画布对象(TCanvas及其派生类)有一种Lock()函数可防止其他线程访问画布,直到调用Unlock()函数。 VCL还包含一种线程安全的列表对象TThreadList。调用TThreadList::LockList()返回列表对象,同时组织其他线程使用列 表直到调用UnlockList()函数。调用TCanvas::Lock()函数或TThreadList::LockList()函数时可以安全地嵌 套。锁定直到最后一个锁定调用匹配到同一线程中相应的解锁调用时才会被释放。 显然这种方法只对部分类有效。<2>,使用重要区段 若对象没有提供内置的锁定功能,可使用重要区段。重要区段像门一样,每次只允许一个线程进入。要使用它,需创建TCriticalSection的全局实 例。TCriticalSection有两个函数:Acquire()(阻止其他线程执行该区段)以Release()(取消对其他线程的阻止)。 每个重要区段都与需要保护的全局内存关联。每个要访问这个全局内存的线程首先要调用Acquire()函数以确保其他线程不能访问它。当线程结束时,要调用Release()函数以便其他线程能继续访问。 例如,应用程序有一个全局重要区段变量pLockXY,可阻止访问全局变量X和Y。任何使用X或Y的线程必须调用重要区段,如下所示: pLockXY->Acquire(); try{ Y=sin(X); } __finally { pLockXY->Release(); }<3>,使用多重读、独占写的同步器 当使用重要区段来保护全局内存时,每次只有一个线程可以使用该内容。这种保护可能超出了需要,特别是当有一个经常读但很少写的对象或变量时更是如此。多个 线程同时读相同内存但没有线程写内存是没有危险的。当有一些经常被读但很少有线程向其写入的全局内存时,可使用 TMultiReadExclusiveWriteSynchronizer对象保护它。这个对象与重要区段一样,但它允许多个线程同时读,只要没有线程 写即可。线程必须有独占访问权才能写使用TMultiReadExclusiveWriteSynchronizer保护的内存。 要使用“多重读、独占写”的同步器,需创建TMultiReadExclusiveWriteSynchronizer的一个全局实例,它与要保护的全局 内存关联。每个需要读内存的线程首先要调用BeginRead()函数。它确保当前无其它线程写内存。线程完成读操作后调用EndRead()函数。任何 线程要写内存的时候必须先调用BeginWrite()函数,结束后调用EndWrite()函数。<4>,共享内存的其他技术 当使用VCL对象时,使用主VCL线程来执行代码,可确保对象不会间接地访问同时被其他线程中的VCL对象使用的内存。若全局变量不需要被多个线程共享,可使用线程变量来代替它。线程可以不需要等待或暂停其他线程。2,等待其他线程 若线程必须等待另一线程完成某项任务,可让线程临时中断执行。然后要么等待另一线程完全执行结束,要么等到另一线程通知完成了该项任务。<1>,等待线程执行结束 要等待另一线程执行结束,使用它的WaitFor()函数。WaitFor()函数直到那个线程终止才返回,终止的方式要么完成了Execute()函数,要么由于一个异常。例如,下面的代码在访问列表中的对象前等待,直到另一线程填满该列表。 void __fastcall TVisitList::Execute() { int fileRes; TFillThread *fl=new TFillThread(false); fillRes=f1->WaitFor(); //以下进行后续处理 } 上例中,列表对象只在WaitFor()函数指出该列表被填满时才能被访问。返回值由被等待线程的Execute()函数指定。然而,因为调用 WaitFor()函数的线程需要直到另一线程的执行结果,无法以代码调用Execute()函数,Execute()函数也无法返回任何值。所以 TFillThread线程的Execute()函数应该设置ReturnValue属性。ReturnValue通过被其他线程调用的 WaitFor()函数返回。返回值是一个证书,由应用程序确定其含意。<2>,等待任务完成 有时,只需等待线程完成一些操作而不是执行结束。为此,可使用一个事件对象。事件对象(TEvent)应具有全局范围以便他们能够为所有线程可见。当一个 线程完成一个被其他线程依赖的操作时,调用TEvent::SetEvent()函数。它发出一个信号,以便任何其他线程可检查并得知操作完成。要关掉信 号则使用ResetEvent()函数。四、调试多线程程序当调试多线程应用程序时,试图跟踪所有并行线程的状态,或在断点停止时判断是哪一个线程的执行往往会使人感到迷惑。可使用Thread Status框来帮助跟踪并控制应用程序中所有的线程。开启Thread Status框的方法是:View|Debug Windows|Threads。当一个调试事件(断点、异常、暂停)发生时,线程状态指示各个线程的状态。右击可定位相应的源代码位置或将其他线程设置为当前线程等。最后要提醒的是,不要使用无意义的多线程。如果一段程序完全是串行的,每一步的操作都需要上一步的结果,那么在这里采用多线程技术就是毫无意义的。[喝小酒的网摘]http://blog.hehehehehe.cn/a/8498.htm
转载于:https://www.cnblogs.com/mypsq/p/5121138.html
BCB 多线程的同步与协调相关推荐
- Java基础知识多线程,同步锁
多线程 /*多线程: 多任务执行,多路径执行优点:提高性能提高效率进程与线程之间的区别:进程 : 系统中的程序,一个进程之间可以包含1~n个线程,系统中资源分配的最小单位,每个进程都有自己的代码与数据 ...
- Linux多线程的同步------读写锁
前面介绍过Linux多线程同步的另外两个方法------互斥锁和信号量 Linux多线程的同步-----信号量和互斥锁_神厨小福贵!的博客-CSDN博客 下面来看一下读写锁: 读写锁和互斥锁都带有一个 ...
- Linux多线程的同步-----信号量和互斥锁
前面两篇给基本概念讲过了,大家有兴趣的可以去看一下: Linux多线程_神厨小福贵!的博客-CSDN博客进程和线程的区别有哪些呢?进程是资源分配的最小单位,线程是CPU调度的最小单位进程有自己的独立地 ...
- java多线程的同步
http://www.blogjava.net/jadmin/archive/2010/03/18/360497.html 多线程的同步依靠的是对象锁机制,synchronized关键字的背后就是利用 ...
- java的知识点32——多线程 并发同步的 性能分析、快乐影院 订票操作
多线程 并发 同步 性能分析 /*** 线程安全: 在并发时保证数据的正确性.效率尽可能高* synchronized* 1.同步方法* 2.同步块* @author Administrator ...
- Android多线程之同步锁的使用
本文主要介绍了Android多线程之同步锁的使用,分享给大家,具体如下: 一.同步机制关键字synchronized 对于Java来说,最常用的同步机制就是synchronized关键字,他是一种基于 ...
- JAVA-初步认识-第十三章-多线程(验证同步函数的锁)
一. 至于同步函数用的是哪个锁,我们可以验证一下,借助原先卖票的例子 对于程序中的num,从100改为400,DOS的结果显示的始终都是0线程,票号最小都是1. 票号是没有问题的,因为同步了. 有人针 ...
- linux多线程编程——同步与互斥
一. 为什么要用多线程技术? 1.避免阻塞,大家知道,单个进程只有一个主线程,当主线程阻塞的时候,整个进程也就阻塞了,无法再去做其它的一些功能了. 2.避免CPU空转,应用程序经常会涉及到RPC,数据 ...
- java 多线程跑数据_java——多线程的实现方式、三种办法解决线程赛跑、多线程数据同步(synchronized)、死锁...
多线程的实现方式:demo1.demo2 demo1:继承Thread类,重写run()方法 packagethread_test;public class ThreadDemo1 extendsTh ...
最新文章
- 数据结构和算法动态可视化
- 定义一个计算字符串有效长度的_一个正方形的小抽屉柜,根据设计草图计算出所需四片木板的长度...
- html抽奖源码_开源FPGA开发板OpenICE 介绍及抽奖
- ubuntu中由apt-get获得的文件包保存在哪里?
- JAVA day04 数组排序,类和对象
- 0031 Java学习笔记-梁勇著《Java语言程序设计-基础篇 第十版》英语单词
- 网易云ncm,QQ音乐qmc,mgg,mflac,酷狗kgm解锁转换为flac格式
- c语言色环电阻计算器源代码,色环电阻在线计算器
- IPv6规模部署及专项督查工作全国电视电话会议
- MyBatis 简单手写的 实现
- OSPF特殊区域TOTAL STUB配置实验
- 在外远程登录公司内网OA系统
- 【JqGrid】JqGrid API 中文说明及用法
- 2020王者营地服务器维护,至尊宝重磅返场,王者营地服务器崩溃,只因玩家等待了五年的它...
- Linux U盘分区格式化 fdisk命令
- pytorch 一个 Tensor的 is_leaf requires_grad 两个属性同时 为 True 才会保存 grad
- 《高级计算机网络》之物联网——大连理工大学研究生课程整理笔记(非常详细,通俗易懂)
- 安装matlab到99%时出现的问题:在您的许可证文件中找不到 SERVER 行。您需要在 ...... 中手动编辑 SERVER
- Ubuntu系统python3.6版本,networkx画关系图显示中文处理
- AI认知架构四十年:发展与挑战
热门文章
- NSString 使用方法总结
- cnetos6.2搭建mysql_基于腾讯云的Centos6.2系统搭建Apache+Mysql+PHP开发环境
- 直接用自己服务器做图床可以吗_我花 9 块钱搭了一个“私人图床”
- C++11构造与禁用默认函数
- FIXML and FpML - Background, Comparison, Integration Interoperability Opportunities
- maven book
- 深入掌握JMS JMSCorrelationID与Selector
- 步步理解 JAVA 泛型编程 – 共三篇
- subprogram or cursor is declared in a package specification and must be defined in the package body
- Python并发编程之:多进程