78 lines
2.3 KiB
C++
78 lines
2.3 KiB
C++
#include <iostream>
|
|
#include <fstream>
|
|
#include <string>
|
|
#include <thread>
|
|
#include <vector>
|
|
#include <memory>
|
|
|
|
#include "FifoQueue.hpp"
|
|
#include "Map.hpp"
|
|
#include "computePi.hpp"
|
|
|
|
|
|
void threadWorker(std::uint16_t threadNum, FifoQueue* threadSafeQueue, Map* threadSafeMap) {
|
|
while(!threadSafeQueue->empty()){
|
|
int index = threadSafeQueue->front();
|
|
threadSafeQueue->pop();
|
|
unsigned int piDigit = computePiDigit(index);
|
|
threadSafeMap->safeInsert(index, piDigit);
|
|
std::cout << ".";
|
|
std::cout.flush();
|
|
}
|
|
}
|
|
|
|
|
|
|
|
int main() {
|
|
FifoQueue* threadSafeQueue = new FifoQueue();
|
|
Map* threadSafeMap = new Map();
|
|
for(int i = 1; i <= 1000; i++){
|
|
threadSafeQueue->push(i);
|
|
}
|
|
//
|
|
// Make as many threads as there are CPU cores
|
|
// Assign them to run our threadWorker function, and supply arguments as necessary for that function
|
|
std::vector<std::shared_ptr<std::thread>> threads;
|
|
for (std::uint16_t core = 0; core < std::thread::hardware_concurrency(); core++)
|
|
// The arguments you wish to pass to threadWorker are passed as
|
|
// arguments to the constructor of std::thread
|
|
threads.push_back(std::make_shared<std::thread>(threadWorker, core, threadSafeQueue, threadSafeMap));
|
|
|
|
//
|
|
// Wait for all of these threads to complete
|
|
for (auto&& thread : threads)
|
|
thread->join();
|
|
std::cout << std::endl << std::endl;
|
|
|
|
std::ifstream piShape("../piShape.txt");
|
|
if(piShape.is_open()){
|
|
std::string c;
|
|
int t = 0;
|
|
int j = 1;
|
|
while(getline(piShape, c)){
|
|
for(int i = 0; i < c.size(); i++){
|
|
if(c[i] == ' '){
|
|
std::cout << " ";
|
|
}
|
|
else{
|
|
if(t == 0){
|
|
std::cout << "3";
|
|
t++;
|
|
}
|
|
else if(t == 1){
|
|
std::cout<<".";
|
|
t++;
|
|
}else{
|
|
std::cout << threadSafeMap->find(j); j++;
|
|
}
|
|
}
|
|
}
|
|
std::cout << std::endl;
|
|
}
|
|
}
|
|
else{std::cout << "file piShape.txt not found or could not be opened" << std::endl;}
|
|
|
|
// std::cout << threadSafeMap->find(i);
|
|
return 0;
|
|
}
|