chaogu ---大写的人！

 1 queue<sometype> shareQueue
 2 
 3 main{
 4     run_server()
 5 }
 6 run_server{
 7     //do something init
 8     ....
 9     
10     //create thread
11     for(int i = 0;i < pollsize;++i){
12         pthread_attr_init(attr[i])
13         pthread_attr_setstacksize(attr[i],1024*120)
14         threads[i] = pthread_create(threadids[i],attr[i],somefunc,args[i])
15     }
16     
17     while(true){
18         __createShareObject__(shareObject) //Pseudo-code
19         pthread_mutex_lock(&mutex);
20         shareQuueue.push(shareObject);
21         pthread_mutex_unlock(&mutex);
22     }
23     
24     //clean up
25     .....
26 }
27 
28 somefunc(){
29     while(true){
30         pthread_mutex_lock(&mutex);
31         if(shareQueue.size() < 1){
32             pthead_mutex_unlock(&mutex);
33             continue;
34         }else{
35             shareObject = shareQueue.pop();
36             pthread_mutex_unlock(&mutex);            
37         }
38         __useShareObjectDoSomething__ //pseudo-code
39     }
40 }
41 
42 
43 不知这样是否能看懂，不是我的代码要保密，而是代码有点难看，
就是我看也要整半天才能看懂。这个结构也就够清晰了。Windows里
面的结构是一样的，只不过pthread的函数换成win32api