多线程锁的问题

lewy7

请教各位看官，下面这段程序是不是多线程锁用得不对？

如果不用线程的试过，没出问题，但是用线程的话就core dumped,Program terminated with signal 6, Aborted.

(gdb) bt
#0  0x0000003866630265 in raise () from /lib64/libc.so.6
#1  0x0000003866631d10 in abort () from /lib64/libc.so.6
#2  0x000000386666a84b in __libc_message () from /lib64/libc.so.6
#3  0x00000038666722ef in _int_free () from /lib64/libc.so.6
#4  0x000000386667273b in free () from /lib64/libc.so.6
#5  0x00000000004014b8 in queue_del (ptr=0x12166010) at queue.c:134
#6  0x0000000000400cb5 in consume (parameter=0x12166010) at main.c:74
#7  0x00000038672064a7 in start_thread () from /lib64/libpthread.so.0
#8  0x00000038666d3c2d in clone () from /lib64/libc.so.6

1. pthread_mutex_t locker= PTHREAD_MUTEX_INITIALIZER;
   
2. pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
   
3. 
   
4. void produce(httpq_queue_t *que)
   
5. {
   
6.         char data[100];
   
7.         int i=9999;
   
8.         while(i-->0){
   
9.                 pthread_mutex_lock(&locker);
   
10.                 str_timestamp(data);   //取微秒级的时间字符串
    
11.                 if( 0 > queue_push(que,i,(void *)data,strlen(data)+1)) //加入队列
    
12.                 {
    
13.                         fprintf(stderr, "Error: %s:%d\n", __FILE__, __LINE__);
    
14.                 }
    
15.                 pthread_cond_signal(&cond); //发送信号给consume线程
    
16.                 pthread_mutex_unlock(&locker);
    
17.         }
    
18. }
    
19. 
    
20. void *consume(void *parameter)
    
21. {
    
22.         char data[100];
    
23.         int i=0;
    
24.         int j;
    
25.         httpq_queue_t *que;
    
26.         que=(httpq_queue_t *)parameter;
    
27.         httpq_quedata_t *container;
    
28.         pthread_mutex_lock(&locker);
    
29.         while(1){
    
30.                 pthread_cond_wait(&cond, &locker);
    
31.                 container=(httpq_quedata_t *)malloc(sizeof(httpq_quedata_t)*que->size);
    
32.                 j=que->size;//当前队列总数
    
33.                 while(j-- > 0)
    
34.                 {
    
35.                         queue_struct_pop(que,container+i);//复制出队列头数据
    
36.                         queue_del(que);//删除队列头数据，这个地方段错误了
    
37.                         i++;
    
38.                 }
    
39.                 free(container);//释放
    
40.                 usleep(1000);
    
41.                 pthread_mutex_unlock(&locker);
    
42.         }
    
43. }
    
44. 
    
45. int main()
    
46. {
    
47.         httpq_queue_t *que;
    
48.         que=NULL;
    
49.         create_queue(&que,"quename",999999);//创建一个最大999999的队列
    
50.        
    
51.         pthread_mutex_init (&locker,NULL);
    
52.         pthread_t consumer_thread;
    
53.         pthread_create(&consumer_thread, NULL, consume, (void *)que);
    
54.        
    
55.         produce(que);
    
56.         pthread_join(consumer_thread,NULL);
    
57. 
    
58.         return 0;
    
59. }

复制代码

hellioncu

你lock在循环外，unlock在循环里，不匹配

lewy7

回复 2# hellioncu
把
    void *consume(void *parameter)
的
    pthread_mutex_lock(&locker);
放到循环里也是一样结果，段错误。

jwj070524

像这种生产者和消费者的问题，尽量使用信号量，条件变量容易发生死锁。既然是queue_del发生段错误，那就到代码中看看是不是逻辑错了

lewy7

回复 4# jwj070524


     现在就是纠结在一个地方，如果改成单线程
     while（1）{
            生产;
            消费;
     }
     这样，就不会有段错误了，所以怀疑是线程锁用的不对。或者说的多线程中使用free和malloc有问题？

Dannysd

在发送信号的后面加个usleep(1000);试试

yulihua49

lewy7 发表于 2014-09-03 11:16
请教各位看官，下面这段程序是不是多线程锁用得不对？

如果不用线程的试过，没出问题，但是用线程的话就 ...

用法，流程完全是错的，再看看书。

正确的生产者流程：

1.          
   
2.         pthread_mutex_lock(&threadLock);
   
3.         release_buf(fnp,&threadQueue);
   
4.         pthread_mutex_unlock(&threadLock);
   
5.         pthread_cond_signal(&threadCond);
   

复制代码

正确的消费者流程：

1.        pthread_mutex_lock(&threadLock);
   
2.         tpp->status=1;
   
3.         while(NULL==(fn_rec=queue_get(fn_buf,&threadQueue))) {
   
4.                 if(threadEnd) break;
   
5.                 tpp->status=0;//置等待标志
   
6.                 pthread_cond_wait(&threadCond,&threadLock);
   
7.                 if(!tidp) break;
   
8.                 tpp->status=1;
   
9.         }
   
10.         pthread_mutex_unlock(&threadLock);
    

复制代码

sanagi1987

我怀疑你的队列操作有误， 循环第二次的时候挂掉的吧？

lewy7

回复 8# sanagi1987
果然是这个问题，谢谢大仙。
下面的代码跑起来没什么大问题了，结贴。
马丹的，看了gdb一点也不靠谱，害得我在free那里找找问题找了好久。

1. 
   
2. pthread_mutex_t locker= PTHREAD_MUTEX_INITIALIZER;
   
3. pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
   
4. 
   
5. void produce(httpq_queue_t *que)
   
6. {
   
7.         char data[100];
   
8.         int i=9999;
   
9.         while(i-->0){
   
10.                 pthread_mutex_lock(&locker);
    
11.                 str_timestamp(data);   //取微秒级的时间字符串
    
12.                 if( 0 > queue_push(que,i,(void *)data,strlen(data)+1)) //加入队列
    
13.                 {
    
14.                         fprintf(stderr, "Error: %s:%d\n", __FILE__, __LINE__);
    
15.                 }
    
16.                 pthread_cond_signal(&cond); //发送信号给consume线程
    
17.                 pthread_mutex_unlock(&locker);
    
18.         }
    
19. }
    
20. 
    
21. void *consume(void *parameter)
    
22. {
    
23.         char data[100];
    
24.         int i=0;
    
25.         int j;
    
26.         httpq_queue_t *que;
    
27.         que=(httpq_queue_t *)parameter;
    
28.         httpq_quedata_t *container;
    
29.         
    
30.         while(1){
    
31.                 pthread_mutex_lock(&locker);
    
32.                 while(que->size == 0){
    
33.                         pthread_cond_wait(&cond, &locker);
    
34.                 }
    
35.                 container=(httpq_quedata_t *)malloc(sizeof(httpq_quedata_t)*que->size);
    
36.                 j=que->size;//当前队列总数
    
37.                [color=Red] i=0;//少了这个[/color]
    
38.                 while(j-- > 0)
    
39.                 {
    
40.                         queue_struct_pop(que,container+i);//复制出队列头数据
    
41.                         queue_del(que);//删除队列头数据，这个地方段错误了
    
42.                         i++;
    
43.                 }
    
44.                 free(container);//释放
    
45.                 usleep(1000);
    
46.                 pthread_mutex_unlock(&locker);
    
47.         }
    
48. }
    
49. 
    
50. int main()
    
51. {
    
52.         httpq_queue_t *que;
    
53.         que=NULL;
    
54.         create_queue(&que,"quename",999999);//创建一个最大999999的队列
    
55.         
    
56.         pthread_mutex_init (&locker,NULL);
    
57.         pthread_t consumer_thread;
    
58.         pthread_create(&consumer_thread, NULL, consume, (void *)que);
    
59.         
    
60.         produce(que);
    
61.         pthread_join(consumer_thread,NULL);
    
62. 
    
63.         return 0;
    
64. }
    

复制代码

lewy7

回复 7# yulihua49


    谢谢，参照的改了流程。不过
     pthread_mutex_unlock(&threadLock);
     pthread_cond_signal(&threadCond);
   这个好像反了。