关于posix线程的几个问题

cugb_cat

4个锁中既然有没释放的，那说明还有线程在使用共享数据，E当然就不能用了，如果都是读的话，使用读写锁

什么名

原帖由 cugb_cat 于 2008-10-30 11:00 发表
4个锁中既然有没释放的，那说明还有线程在使用共享数据，E当然就不能用了，如果都是读的话，使用读写锁

是这样的，E是与时间相关的数据处理，E线程在周期性的时间到时，要求A、B、C、D停止写，如何通知A、B、C、D没释放的锁解锁？

cugb_cat

原帖由 什么名 于 2008-10-30 11:10 发表

是这样的，E是与时间相关的数据处理，E线程在周期性的时间到时，要求A、B、C、D停止写，如何通知A、B、C、D没释放的锁解锁？

那就在ABCD中各设置一个变量，这4个线程循环写的时候，一边写一边检查该变量的值，当E要处理数据时，先try lock一下，如果有线程没解锁，就修改相应变量的值，相应的线程检查到变量的值变了，就去解锁。

什么名

原帖由 cugb_cat 于 2008-10-30 11:16 发表

那就在ABCD中各设置一个变量，这4个线程循环写的时候，一边写一边检查该变量的值，当E要处理数据时，先try lock一下，如果有线程没解锁，就修改相应变量的值，相应的线程检查到变量的值变了，就去解锁。

明白你的意思了，按照如下方式是吗？

1. 
   
2. 约定 flagA = 1 E线程操作数据， flagA = 0 , A,B,C,D 操作数据
   
3. 
   
4. 
   
5. A:
   
6. 
   
7. pthread_mutex_lock(&lockerA);
   
8. 
   
9. 
   
10.     while(（flagA==0）&&(数据未写完)) {
    
11.         写数据;
    
12.     }
    
13. 
    
14.     if (flagA==1) {
    
15.         pthread_mutex_unlock(&lockerA);  //  解锁语句1，采用goto UNLOCK吗？
    
16.     }
    
17. 
    
18.    ……
    
19. UNLOCK:
    
20. pthread_mutex_unlock(&lockerA);  //  解锁语句2
    
21. 
    
22. 
    
23. 
    
24. E:
    
25. 
    
26. if (pthread_mutex_trylock(&lockerA) == EBUSY ) {
    
27. 
    
28.         flagA = 1;                 // tell A to unlock
    
29.         pthread_mutex_lock(&lockerA);
    
30.        
    
31.         写数据 a, b, c, d;
    
32.        
    
33.         pthread_mutex_unlock(&lockerA)
    
34. 
    
35. } else { // get the locker
    
36.        
    
37.         写数据 a, b, c, d;       
    
38.         pthread_mutex_unlock(&lockerA)
    
39. }
    

复制代码

有个问题，线程A等在发现flag=1时解锁后下一次获得时间片时，不会继续从if之后的语句执行 解锁语句2了吧？否则会解锁两次。

[ 本帖最后由 什么名 于 2008-10-30 11:47 编辑 ]

什么名

原帖由 什么名 于 2008-10-30 11:39 发表

明白你的意思了，按照如下方式是吗？

约定 flagA = 1 E线程操作数据， flagA = 0 , A,B,C,D 操作数据


A:

pthread_mutex_lock(&lockerA);


    while(（flagA==0）&&(数据未写完)) {
        写数据; ...

改了一下，在flag=1时，A不可写，此时应该让其阻塞，结合条件变量调用pthread_cond_wait，这样会自动解锁，而等条件成立时候又会自动加锁，从而继续A线程，
不会引起由goto跳转早餐部分代码流程被忽略，也不会有多次被解锁的问题，不知道是否正确呢？
但仍然发现几个问题“

1. 
   
2. //约定 flagA = 1 E线程操作数据， flagA = 0 , A,B,C,D 操作数据
   
3. 
   
4. 
   
5. //A:
   
6. 
   
7. pthread_mutex_lock(&lockerA);
   
8. 
   
9.     while((flagA==0) && (数据未写完)) { // 问题1: 影响性能，同时如果写数据是多个语句，而且耗时很长，照样不能及时解锁
   
10.         写数据;
    
11.     }
    
12. 
    
13.     if (flagA==1) {
    
14.         //pthread_mutex_unlock(&lockerA);
    
15.         pthread_cond_wait(&cond, &locker); // 阻塞
    
16.         //  // 问题2: 前面wihle中未写完成的数据怎么办？
    
17.     }
    
18. 
    
19.     ……
    
20. 
    
21. pthread_mutex_unlock(&lockerA);
    
22. 
    
23. 
    
24. 
    
25. //E:
    
26. 
    
27. if (pthread_mutex_trylock(&lockerA) == EBUSY ) {
    
28. 
    
29.         flagA = 1;                 // tell A to unlock
    
30.         pthread_cond_signal();  //notify A to unlock
    
31. 
    
32.         pthread_mutex_lock(&lockerA);
    
33. 
    
34.         写数据 a, b, c, d;
    
35.        
    
36.         pthread_mutex_unlock(&lockerA);
    
37. 
    
38. 
    
39. } else { // get the locker
    
40.        
    
41.         写数据 a, b, c, d;       
    
42.         pthread_mutex_unlock(&lockerA);
    
43. }
    

复制代码

[ 本帖最后由 什么名 于 2008-10-30 13:06 编辑 ]