请教关于线程的问题

何必抱怨

这是生产者消费者不。。

yulihua49

Unix_C_Linux 发表于 2015-08-21 10:01
大家好,有主进程A接收数据,现在想异步的对这些数据进行操作,然后临时存储,开了一个线程对他操作。我想问 ...

这就是我的处理线程,消费者。可以有很多线程在干：

1. 
   
2. static void * cli_sched(void *reg)
   
3. {
   
4. tpool_node *thp=(tpool_node *)reg;
   
5. int ret;
   
6. struct epoll_event event;
   
7. dlq_node *dlp;
   
8. 
   
9.         pthread_detach(thp->tid);
   
10.         thp->flg=0;
    
11.         ShowLog(2,"%s:tid=%lX created",__FUNCTION__,thp->tid);
    
12.         while(1) {
    
13.           if(lnum<LNUM) { //有几个线程在等epoll
    
14.                 lnum++;
    
15.                 ret = epoll_wait(epfd, &event, 1,-1);//等待服务器返回的消息
    
16.                 lnum--;
    
17.                 if(ret<0) break; //epfd关闭了，退出
    
18.                 dlp=(dlq_node *)event.data.ptr;
    
19.                 to_epoll(dlp,EPOLL_CTL_DEL,0);
    
20.           } else { //其他线程在等队列
    
21.                 pthread_mutex_lock(&tmutx);
    
22.                 while(NULL==(dlp=dlq_get(&tqueue))) { //提交给本线程池处理的消息
    
23.     //这就是告诉你的，等消息。其他线程加入队列后：pthread_cond_signal(&tcond);
    
24.                        pthread_cond_wait(&tcond,&tmutx);
    
25.                  }
    
26.                 pthread_mutex_unlock(&tmutx);
    
27.           }
    
28.           if(dlp->callback) ret=dlp->callback(dlp);
    
29.         }
    
30.         thp->flg=-1;
    
31.         return NULL;
    
32. }
    
33. 
    

复制代码

yulihua49

Unix_C_Linux 发表于 2015-08-21 10:01
大家好,有主进程A接收数据,现在想异步的对这些数据进行操作,然后临时存储,开了一个线程对他操作。我想问 ...

二者都是可以多线程的。等待过程不消耗CPU.

1. 
   
2. //消费者
   
3. dlq_node *Q_get()
   
4. {
   
5. dlq_node *dlp;
   
6.         pthraed_mutex_lock(&Q_free.mut);
   
7.         while(NULL==(dlp=dlq_get(&Q_free.queue))) {
   
8.                 pthread_cond_wait(&Q_free.cond,&Q_free.mut);//等生产者通知
   
9.         }
   
10.         pthraed_mutex_unlock(&Q_free.mut);
    
11.         return dlp;
    
12. }
    
13. 
    
14. //生产者
    
15. int Q_release(dlq_node *dlp)
    
16. {
    
17. int ret;
    
18.         if(!dlp) return -1;
    
19.         pthraed_mutex_lock(&Q_free.mut);
    
20.         ret=dlq_add(&Q_free.queue,dlp);
    
21.         pthraed_mutex_unlock(&Q_free.mut);
    
22.         phread_cond_signal(&Q_free.cond);//通知消费者
    
23.         return ret;
    
24. }
    

复制代码

其实挺简单的，就是把你原来想sleep的地方换成pthread_cond_wait就行了。

1. 
   
2. while(NULL==(dlp=dlq_get(&Q_free.queue))) {
   
3.           usleep(1000);
   
4. }
   

复制代码