Параллельное и распределенное программирование на С++

существующий поток о необходимости обработки запроса. Этот подход к реализации модели делегирования представлен в листинге 4.7.

// Листинг 4.7. Подход 2: скелет программы реализации . модели управляющего и рабочих потоков

pthread_t Thread[N]
// boss thread
{
    pthread_create(&(Thread[1]...taskX...);
    pthread_create(&(Thread[2]...taskY...);
    pthread_create(&(Thread[3]...taskZ...);
    //...
    loop while(Request Queue is not empty
       get request
       classify request
       switch(request type)
       {
           case X :
                    enqueue request to XQueue
                    signal Thread[1]
           case Y :
                    enqueue request to YQueue
                    signal Thread[2]
           case Z :
                    enqueue request to ZQueue
                    signal Thread[3]
           //...
       }
   end loop
}
void *taskX(void *X)
{
   loop
       suspend until awaken by boss
       loop while XQueue is not empty
          dequeue request
          process request
       end loop
   until done
{
void *taskY(void *Y)
{
   loop
       suspend until awaken by boss
       loop while YQueue is not empty
          dequeue request
          process request
       end loop
   until done
}
void *taskZ(void *Z)
{
   loop
       suspend until awaken by boss
       loop while (ZQueue is not empty)
          dequeue request
          process request
       end loop
   until done

} //.. .

В листинге 4.7 управляющий поток создает N рабочих потоков (по одному для каждого типа задачи). Каждая задача связана с обработкой запросов некоторого типа В цикле событий управляющий поток извлекает запрос из очереди запросов, определяет его тип, ставит его в очередь запросов, соответствующую типу, а затем оправляет сигнал потоку, который обрабатывает запросы из этой очереди. Функции потоков также содержат циклы событий. Поток приостанавливается до тех пор, пока не получит сигнал от управляющего потока о существовании запроса в его очереди. После «пробуждения» (уже во внутреннем цикле) поток обрабатывает все запросы до тех пор, пока его очередь не опустеет.

Использование модели сети с равноправными узлами

В модели равноправных узлов один поток сначала создает все потоки, необходимые выполнения всех задач. Каждый из равноправных потоков обрабатывает запросы, поступающие из собственного входного потока данных. В листинге 4.8 представлен скелет программы, реализующий при разделении программы на потоки метод равноправных узлов

Листинг 4.8. Скелет программы реализации модели  равноправных потоков

pthread_t Thread[N]
// initial thread
{
    pthread_create(&(Thread[1]...taskX...);
    pthread_create(&(Thread[2]...taskY...);
    pthread_create(&(Thread[3]...taskZ...);
    //...
  }
void *taskX(void *X)
{