-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathprime_number_find.cpp
96 lines (75 loc) · 1.64 KB
/
prime_number_find.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
//Numeros Primos
// Primos Aleatorios
// Threads em Vetor, Hard Threads, 2Threads per Core
// Dinamica
#include <iostream>
#include <stdlib.h> //Numero Random
#include <thread> //Threads
//Saida da Lista
void p_out(int** A, int x){
std::cout<<"\n\n";
for(int i=0; i<x; i++){
std::cout<<"\n["<<(i+1)<<"]\t\t"<<A[i][1]<<"\t\t"<<A[i][0];
if(A[i][1] == 1) std::cout<<"\t Primo";
}
std::cout<<"\n\n";
}
void prime_Fill(int** A, int i){
A[i][1] = 1;
A[i][0] = (rand()%(i+10))+2;
}
void prime_Find(int** A, int y, int z){
for(int i = y; i < z; i++){
for(int j = (A[i][0])-1; j > 1; j--){
if(( (A[i][0]) %j) == 0){
A[i][1] = 0;
j = 0;
}
}
}
}
int main(){
//Tamanho da Lista
int x = 200000;
//A(x,2)
int** A = new int*[x];
for(int i=0; i<x; i++){
A[i] = new int[2];
prime_Fill(A,i);
}
//Numero de Cores(Nucleos) do Processador
unsigned int cores = std::thread::hardware_concurrency();
std::cout<<"\nCore Count:"<<cores<<"\n";
//Numero de 2 Threads/Core (Piper)
int n = cores*2;
//Intervalo de linhas
int y = x/n;
//Vetor de Threads
std::thread t00[n];
//Vetor de Threads
for(int i=0; i < n; i++){
int ini = i*y;
int fim;
if(i+1 == n) fim = x;
else fim = (i+1)*y;
std::cout<<"\nThread ["<<i<<"]: "<<ini<<" <-> "<<fim<<".";
//Parametro de Threads
t00[i] = std::thread(prime_Find,A,ini,fim);
}
//Join das Threads
for(int i=0; i < n; i++){
t00[i].join();
}
bool exec = false;
while(exec == false){
for(int i=0; i < n; i++){
exec = (exec)|(t00[i].joinable());
}
exec = ~exec;
std::cout<<"\nThread execution";
}
std::cout<<"\nThread terminada";
//Saida Lista
p_out(A,x);
return 0;
}