Linux下的pv操作

　　关于pv操作部分的内容，其实算不上什么新的东西。但是它对于我们理解信号量、消息处理部分的工作还是有很大帮助的。之前我们给出了一个win32的处理方案，但是实现的比较草率。所以我们今天可以利用linux上的信号量函数把这个功能重新实现一遍。51Testing软件测试网p*@J\Baz

　　（1）linux下面信号量的基本函数51Testing软件测试网9iiv'tj8F``*~.N

@ O9lO&nm,M0　　a）创建信号量  sem_init51Testing软件测试网%md0o"d!iD{| k

　　b）等待信号量 sem_wait

　　c）释放信号量 sem_pos

L%H1t \3s7egjvw0　　d）删除信号量 sem_destroy

q-AY&{*kU0　　（2）编写pv操作函数51Testing软件测试网w,e~+B6h R%G1P

　　之前在编写pv操作的时候，没有考虑到消息处理的时序问题，所以在某些极端的情况下可能会造成一些问题。所以本次pv操作采用了循环队列的形式，保持了消息的先后入队顺序。这样对于线程收到的各种消息就可以依次进行处理解决了。同样，我们文件编译的方法非常简单，shell下输入gcc sem.c -g -o sem -lpthread即可。

　　可能有同学会问，单独的循环队列和pv操作处理上有什么差别？其实差别很简单，pv可以是不同线程向一个线程发送消息，而循环队列只能接受一个线程发送的消息，否则处理上就麻烦了。

#include <stdio.h>51Testing软件测试网[O?W,b*q
#include <malloc.h>
2WO U$}%xaF!_P0#include <string.h>
kZ}8[W^0#include <pthread.h>
N+T7F&c/E.I{6W0#include <semaphore.h>51Testing软件测试网9~b5vS?`M"y5h

-v[/_Ed A8gh:{U0struct MSG
et] dn'g0{
qE)n5Z0A+I0 sem_t s_empty;51Testing软件测试网.rpEb P G3Q*fL%wz|
 sem_t s_full;51Testing软件测试网8T7gLc}3Mu
 sem_t s_msg;51Testing软件测试网no Ky&g%Y0D
 int* p_buffer;51Testing软件测试网.HeMm!^Nsa
 int start;
WY6h@&M0 int end;
Kr6@ e;ZONc0 int count;
&J @\.q6|&C0};51Testing软件测试网:WgTv n2~0?j$k4n

C? ^ k/A(P^:or051Testing软件测试网4[BAN2E%}P
#define STATUS int51Testing软件测试网#u"h}:fB-H4^C
#define TRUE 151Testing软件测试网Z:as/z.Xr^
#define FALSE 0
!` R9?Ll,u0static struct MSG* p_msg = NULL;

-L5V"S*SOBp!E-b'H,T0struct MSG* alloc_msg(int count)
7J:gjc
h)G:}#L;T4z0{51Testing软件测试网%Z7U7Ik%I3lq
 struct MSG* p_msg;51Testing软件测试网C| v:{,v}
 p_msg = (struct MSG*) malloc(sizeof(struct MSG));
~JZ{(^4D0 if(NULL == p_msg)
7[m:RtMLK0 {
?TX%{&`5Ln0  goto error1;51Testing软件测试网Px8I vX%A a
 }51Testing软件测试网1c&n!KWbO!~
 memset(p_msg, 0, sizeof(struct MSG)); 51Testing软件测试网(s{8^.]n JH
 p_msg->count = count;

 p_msg->p_buffer = (int*)malloc(sizeof(int)* count);51Testing软件测试网(D,eU{ d"R\d7S
 if(NULL == p_msg->p_buffer)51Testing软件测试网.R&Nu6Pe(n"_es
 {
%{/wc,| lF0  goto error2;
/Td8d#CwS@0 }51Testing软件测试网J4D2}ZJO.DS

 sem_init(&p_msg->s_empty, 0, count);51Testing软件测试网WTT9N
})Gx2xV
H
 sem_init(&p_msg->s_full, 0, 0);
WW,|3Qix'|0 sem_init(&p_msg->s_msg, 0, 1);51Testing软件测试网v.sF k B_e
~/sS

(q4G B#Zd$}{1s0 return p_msg;

*|*r%S|$lJb^7\}7u0error2:51Testing软件测试网a(M-~h/WAb
 free(p_msg);

error1:
BHl1f/|0 return;51Testing软件测试网6A2H4p.c6S M,\"ZWq#x
}

C!W7BqT z051Testing软件测试网.i$Q$rF*A6O9]^
void del_msg(struct MSG* p_msg)
/P M|2JM@~#w]0{
cpN'`f'[(M*^+F"qCC9x0 if(p_msg)51Testing软件测试网l/g
z#Z!I {O
 {
#VR5J'Y+s#i x0  if(p_msg->p_buffer)51Testing软件测试网oaGz7d*h8xs2]
  {51Testing软件测试网7C;`-{A-U7Xr6_
   free(p_msg->p_buffer);51Testing软件测试网| Q@;|H;O ?
  }
W wr0J+DNDZ0  
N+fM5`N`H0  sem_destroy(&p_msg->s_msg);51Testing软件测试网}&t ve|/F%O
  sem_destroy(&p_msg->s_full);
EG3[1zI)K| Be'm0  sem_destroy(&p_msg->s_empty);
qUG2gHM4B_3W0  free(p_msg);
$CyEU([)Cf4`6})D0 }51Testing软件测试网#B bbr0H#{_
}51Testing软件测试网x1g&{$BZ S

aH/Rq E$lX9X0D0STATUS put_msg(struct MSG* p_msg, int data)
[nIfpA,X0{
5_3FXncY0 if(NULL == p_msg )51Testing软件测试网 | jA_9D'c^
 {51Testing软件测试网\b _-N Nbk"V"m
  return FALSE;51Testing软件测试网W6ru%l2Uje|#V{
 }

 sem_wait(&p_msg->s_empty);51Testing软件测试网PT-t5r }
 sem_wait(&p_msg->s_msg);
._9V-A-jB;E0 p_msg->p_buffer[p_msg->start] = data;
e7v7O e$qP}0 p_msg->start = (p_msg->start + 1) % p_msg->count;
g"IJ&n.]s0 sem_post(&p_msg->s_msg);
'SbsxNC"y8d0 sem_post(&p_msg->s_full);

\:?GLCk.N0 return TRUE;
!ldC7M+HV0}

u y-rC o"H~.W0STATUS get_msg(struct MSG* p_msg, int* p_buf)51Testing软件测试网BJ1^_:Q2T
{51Testing软件测试网?f9@MgGo0G5x
 if(NULL == p_msg || NULL == p_buf)
)]4K7xM/E[Lxi#^l0 {51Testing软件测试网/~4WwWd-d
  return FALSE;
!zq@ ].F0 }51Testing软件测试网S(Oe/Xu,W

 sem_wait(&p_msg->s_full);51Testing软件测试网;]y[e"K9Q6P|
 sem_wait(&p_msg->s_msg);51Testing软件测试网N0g@.J'| I
 p_buf[0] = p_msg->p_buffer[p_msg->end];
kK1XIV G{vzC0 p_msg->end = (p_msg->end + 1)% p_msg->count;
,Nh3AYC5E0 sem_post(&p_msg->s_msg);
$t4mK%E/Hc4VSr0 sem_post(&p_msg->s_empty);

`V;F{ H,zG Cs0 return TRUE;
R
?-H:~ jq
Y$H0}51Testing软件测试网Q/K1VZ1] b4`

:Xz.W:a0Ox%l051Testing软件测试网9z/o ?]g7K-F6LC5[ ~
void* set_func(void* args)51Testing软件测试网n^ iV G?&]0eg t
{
2l)y OF"k0 int index = 100;51Testing软件测试网5qK)zatxP
_J
 51Testing软件测试网@a,L:T`&jK(eL
 while(1)51Testing软件测试网0z/O4y6c0X+|F
 {
A3I^yE/~%L0  put_msg(p_msg, index);51Testing软件测试网]XFdq$l g*A9?;A
  printf("set %d\n", index);
XU2wY!^0  index ++; sleep(1);51Testing软件测试网-yB` bKO [7QG
 }51Testing软件测试网*?@9~s/o*|UEb

 return NULL;51Testing软件测试网/Tl jg b:pH-Db
}51Testing软件测试网C-g%~6lrM$}

Q'?AT!Co0
_ ^ |p0F&^-D0void* get_func(void* args)
5V!k*T2kQE3Yb]#c0{51Testing软件测试网 X+XmNJ3Dq
 int data;

~(oW+p)QGI0 while(1)51Testing软件测试网 ~*i!^*n'`
 {51Testing软件测试网+[Q#CPnz,CzED
  get_msg(p_msg, &data);51Testing软件测试网N2F-h(zsV(Te Q
  printf("get %d\n", data);
pM)@oY
Ak5@0  sleep(1);51Testing软件测试网9\I5|z9R
 }51Testing软件测试网 ]ww
B"v2M4M

(XD Fk/H^Fi[9Z|0 return NULL; 
RY2c9WUT0}51Testing软件测试网 r3r'rK$U+}

+x*n/Z3W%|2v051Testing软件测试网wbv,O u$\q
int main(int argc, char* argv[])51Testing软件测试网Z5s/[m5Un
{51Testing软件测试网8T0^\ f;{*];LE-~
 pthread_t pid1, pid2; 51Testing软件测试网@5s9Z1z+J{
 int index; 

-z*?^I)G&q"e0 p_msg = alloc_msg(10);51Testing软件测试网(_
_7pT`hV
 if(NULL == p_msg)51Testing软件测试网{'E:v3zX"G\#pb[$`:oz
 {51Testing软件测试网4@F?w,X
  goto end;
*Dl{%}^;EF^0 }

t+Ys8K8x)gPU0 if(pthread_create(&pid1, NULL, set_func, NULL))
K'o&eN(B*k$`(F/r*X!j0 {
0MA [9CD8S0  goto end;
`7M:wh5~){eTV0 }51Testing软件测试网_
hLiyl

Mr
[@0w"m0 if(pthread_create(&pid2, NULL, get_func, NULL))
m,bpC.u%j}:k-^0 {51Testing软件测试网VU%_U1TX`V6BR6p
  goto end;51Testing软件测试网,s({b^` n
 }51Testing软件测试网*t6Oc b)[0q6KK

 while(1)
)~Z^&`U9c.B-n2J8w@0 {
}9IF2p"r3AMb0  sleep(0);51Testing软件测试网7o&GM&E.[9v;v\^5]n K
 }

end:51Testing软件测试网8]W6q"S;Jd-u(g
 return 1;51Testing软件测试网3iod`]v&l
}