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

66            depthFirstTraversal(NewDirectory.c_str());
67         }
68         else{
69                 if(isRegular(FileName)){
70                    int Flag;
71                    Flag = FileName.find('.cpp»);
72                    if(Flag > 0){
73                       pthread_mutex_lock(&CountMutex);
74                         FileCount++;
75                      pthread_mutex_unlock(&CountMutex);
76                       pthread_mutex_lock(&QueueMutex);
77                         TextFiles.push(FileName);
78                      pthread_mutex_unlock(&QueueMutex);
79                   }
80                }
81        }
82
83     }
84     EntryP = readdir(DirP);
85 }
86   closedir(DirP);
87 }
88
89
90
91 void *task(void *X)
92 {
93   char *Directory;
94   Directory = static_cast<char *>(X);
95   depthFirstTraversal(Directory);
96   return(NULL);
97
98 }

Программа 4.6 содержит поток-«потребитель», который выполняет ных ключевых слов.

// Программа 4.6

1 void *keySearch(void *X)
2 {
3   string Temp, Filename;
4   less<string> Comp;
5
6   while(!Keyfile.eof() && Keyfile.good())
7   {
8      Keyfile >> Temp;
9      if(!Keyfile.eof()){
10        KeyWords.insert(Temp);
11     }
12  }
13  Keyfile.close();
14
15  while(TextFiles.empty())
16  { }
17
18  while(!TextFiles.empty())
19  {
20     pthread_mutex_lock(&QueueMutex);
21     Filename = TextFiles.front();
22     TextFiles.pop();
23     pthread_mutex_unlock(&QueueMutex);
24     Infile.open(Filename.c_str());
25     SearchWords.erase(SearchWords.begin(),SearchWords.end());
26
27     while(!Infile.eof() && Infile.good())
28     {
29        Infile >> Temp;
30        SearchWords.insert(Temp);
31     }
32
33     Infile.close();
34     if(includes(SearchWords.begin(),SearchWords.end(),
           KeyWords.begin(),KeyWords.end(),Comp)){
35         Outfile << Filename << endl;
36         pthread_mutex_lock(&CountMutex);
37          FileCount--;
38         pthread_mutex_unlock(&CountMutex);
39         FoundCount++;
40     }
41   }
42   return(NULL);
43
44 }

Программа 4.7 содержит основной поток для потоков модели «изготовитель-потребитель», реализованных в программах 4.5 и 4.6.

// Программа 4.7

1 #include <sys/stat.h>
 2 #include <fstream>
 3 #include <queue>
 4 #include <algorithm>
 5 #include <pthread.h>
 6 #include <iostream>
 7 #include <set>
 8
 9 pthread_mutex_t QueueMutex = PTHREAD_MUTEX_INITIALIZER;
10 pthread_mutex_t CountMutex = PTHREAD_MUTEX_INITIALIZER;
11
12 int FileCount = 0;
13 int FoundCount = 0;
14
15 int keySearch(void);
16 queue<string> TextFiles;