Я реализовал параллельную очередь с двумя методами: добавить (поставить в очередь) и удалить (удалить из очереди).
Чтобы протестировать свою реализацию с использованием двух потоков, я сгенерировал 10 (NUMBER_OF_OPERATIONS) случайных чисел от 0 до 1 в методе getRandom(). Это позволяет мне создавать различные распределения операций добавления и удаления.
Метод doWork разделяет проделанную работу по количеству потоков.
ПРОБЛЕМА: идентификатор потока, который я передаю из основной функции, не соответствует идентификатору потока, который получает метод doWork. Вот несколько примеров прогонов:
#define NUMBER_OF_THREADS 2
#define NUMBER_OF_OPERATIONS 10
int main () {
BoundedQueue<int> bQ;
std::vector<double> temp = getRandom();
double* randomNumbers = &temp[0];
std::thread myThreads[NUMBER_OF_THREADS];
for(int i = 0; i < NUMBER_OF_THREADS; i++) {
cout << "Thread " << i << " created.\n";
myThreads[i] = std::thread ( [&] { bQ.doWork(randomNumbers, i); });
}
cout << "Main Thread\n";
for(int i = 0; i < NUMBER_OF_THREADS; i++) {
if(myThreads[i].joinable()) myThreads[i].join();
}
return 0;
}
template <class T> void BoundedQueue<T>::doWork (double randomNumbers[], int threadID) {
cout << "Thread ID is " << threadID << "\n";
srand(time(NULL));
int split = NUMBER_OF_OPERATIONS / NUMBER_OF_THREADS;
for (int i = threadID * split; i < (threadID * split) + split; i++) {
if(randomNumbers[i] <= 0.5) {
int numToAdd = rand() % 10 + 1;
add(numToAdd);
}
else {
int numRemoved = remove();
}
}
}