178  4.  ++-   

//  4.9.    
//              

//. . .

pthread_t Thread[N]

Queues[N]

//  .
{

       
stagel.

pthread_create(&(Thread[1]...stagel...) ;

pthread_create(&(Thread[2]...stage2...) ;

pthread_create(&(Thread[3]...stage3...) ;

//. . .
}

void *stageX(void *X)
{



     

  .
 while ( XQueue  )
   .
   .
     .
 
 
re turn(NULL)
}

// . . .

  4.9  N   N .   
       ,     ,
    .      -
.         ,   
     .    
  .      -
, ,        
(  ).

4.11.4.   "-
"

  "-" -""  ,
"" -"" (  -"" -
  ).     ,   :

 ,   .   4.10   -
   "-" (   -
   4.5, 4.6  4.7).