- 在线时间
- 0 小时
- 最后登录
- 2007-9-23
- 注册时间
- 2004-9-10
- 听众数
- 3
- 收听数
- 0
- 能力
- 0 分
- 体力
- 9975 点
- 威望
- 7 点
- 阅读权限
- 150
- 积分
- 4048
- 相册
- 0
- 日志
- 0
- 记录
- 0
- 帖子
- 1893
- 主题
- 823
- 精华
- 2
- 分享
- 0
- 好友
- 0

我的地盘我做主
该用户从未签到
 |
< >最近在写一个程序用到了多线程,所以对CB下的多线程有一定的学习。1 ~' y1 V9 o, ^
现在把自己的一些心得讲一下。水平有限,写的很粗略,请大家见谅。</P>! R* o) ]' r: d
< >CB相对于VC来说,在CB下写多线程程序是很简单的。不仅是VCL中有TThread这个类。封装了那些关于多线程的WINDOW API。我觉得更方便的是他提供了
( S/ e. k2 s7 b" w6 q! C5 y; O直接访问主VCL线程中对象的能力。可以很容易的和主线程中的窗体,控件
+ Y; k' e! S- D打交道。和单线程的方式没有太多区别。只是在有多个线程都要访问主线程
j9 D5 K/ ? k& k6 d中的对象(比如访问同一个窗体上的StringGrid).只要用Thread的Synchronize方法来调用那段访问主VCL线程的代码(具体请看帮助),我们就不用担心访问冲突的问题了。而且对于多线程的同步和互斥,CB也对WINDOW 编程中那些机制进行了封装。比如对临界区CriticalSection封装为TCriticalSection.事件Event封装为TEvent.这些类相当简单好用。
9 U5 |' h$ D, } Q/ r$ \) x下面就是我觉得比较重要的几点,供大家参考.</P>1 o/ i9 B4 x6 H& \% v$ E
< ># ]% d- B% }9 s/ V
1。TThread的WaitFor方法。是等待一个线程返回。其返回值在这个线程里可以任意设定。以便在该线程返回的时候让调用他的线程知道他的运行情况。 , k$ K5 @8 O$ u; U
9 u& S7 \' y+ ]! t& z* \: w. \
在TThread的 OnTerminate事件中做线程的清除工作。他不是线程运行的一部分。 0 N6 C. E7 k, Q5 W9 O" `; `. y w
而是主VCL线程的一部分。所以在其中不能访问Thread的局部变量(如 int __thread i)
" Q9 u8 b, k$ D1 u$ F" n你可以把清楚代码写在这里,不用管现在在EXCUTE()方法执行到了哪个地方。
8 {, B& W0 K9 O3 S" l4 F这么看起来有点类似于C++里的 finally 块的作用。 * a4 `; L: e2 T+ s- [, P1 d7 \
' b! S; o5 ^1 [" w
2。TEvent很重要。实现线程的同步。WaitFor(int Timeout)功能类似于 / ^$ |1 S( j! g" {% r
WINDOW API WaitforSingleObject().返回值包括: 4 H* e P5 ~' u- f( b/ j/ G
其中参数Timeout可以设为INFINITE表示永久等待,但这样,程序很容易死在这里。 3 ^6 |8 W2 |7 S6 U+ K5 ?
: n8 e$ S9 U* r8 T! e5 f8 LwrSignaled 该事件发生(成功返回).
/ n X9 l' b! J4 y9 [' f, e( IwrTimeout 等待超时. + a: u8 U) u D
wrAbandoned 在该事件的超时期限到达前,该事件对象已经被毁灭了。. b4 P& l8 c+ P, L
wrError 在等待过程中有异常产生,要知道具体产生的错误要查看 TEvent的LastError
1 W& X" V! @% z/ o/ ~属性。 $ o O1 t* E$ x) _; h
& w5 q& [) W0 F1 k( M6 w& f8 W, Z
3? TCriticalSection
8 R1 Z0 d, N4 O7 I8 j' p+ r7 k* k这个相当于WIN32编程中的临界区。
; d) x* d% k) N1 r) Q2 R6 Y6 w8 u在多线程编程中,多个线程需要访问同一个公用变量的时候。 ' P* f/ }* G; I3 x- S, t. X
" G+ H, A$ r& t/ E0 ^. m1 y4 p来保证访问的正确性。对公用变量访问的代码写在Enter();和Leave()之间。 . ]* ~* U% H, N( ]
比如有个公用变量 Count;
7 [8 T7 f t( e8 ~! s E以下代码 : ) @3 p! H( g+ w& z! ?9 n0 F8 J
TCriticalSection * pSection=new TCriticalSection(); ( |( H/ N8 O, q Q
pSection->Enter(); 8 u* d9 C! I6 u: S- A1 h
Count++; % W/ j- P% k7 F1 U
pSection->Leave();
2 p# f" [/ p F# @' h- I% H9 B7 Q3 Gdelete p;
+ H( ~ m, C, ?# o, M8 k0 `
1 n9 ]* W) Y) L5 k a9 o. MEnter()方法进入临界区,对其中的公用变量加锁。
% H0 R- n8 n: Z6 MLeave()方法离开临界区,对其中的公用变量解锁。
5 p3 h) A# c$ c% r# O
* W2 u+ f) q: L/ w0 {3 J; O * S- X; q8 J/ K U
4.TMultiReadExclusiveWriteSynchronizer * o; ~4 `* U4 V% ]6 b. k
用来处理类似于多个生产者和多个消费者的问题。这里的消费者是指
, C$ H5 k( @) B) J. E o% L对公用变量进行读操作的线程。" B) F2 }+ g+ ~6 Y; C! p! q
生产者是对公用变量进行写操作的线程。</P>; v, W; } }- G7 Z7 m
< >四个方法。
0 M! C2 j9 t; I9 d( r" m BeginRead
% o& f; B [+ X$ k2 {2 ?, X1 w EndRead
# M" g# o' G* [* O) l9 I( R: I% p这两个方法用于消费者。
7 R3 C4 \4 \8 N/ f8 R BeginWrite/ L, {: k2 e9 v
EndWrite
+ q8 @: c m/ ?8 L% w W这两个方法用于生产者。</P>5 G* V! @7 l3 n. K8 y- B
< >使用的时候就是要把这个TMutiReadExclusiveWriteSynchronizer 定义一个全局变量。
0 W6 ]) ?7 X, D: ^7 N然后在其他线程中访问他。</P>
, d' {- Q- J T# i
$ n8 m7 Q! j- y# Q- w/ p" E. g0 ^. L< >' i# c! }4 W% n5 W/ L
</P> |
zan
|