MAX_NUMBER를 1'000'000까지 하면 답이 안나오는데 혹시 어떤게 문제인지 봐주실 수 있나요?
221
작성한 질문수 10
1,000번이나 100'000번까지 하면 바로 답이 나오는데 100만번으로 설정하면 계속 기다려도 감감무소식이라서 문제를 잘 모르겠습니다 ㅠㅠ.
#include "pch.h"
#include "CorePch.h"
#include "CoreMacro.h"
#include "ThreadManager.h"
#include <iostream>
// 소수 구하기
// 1과 자기 자신으로만 나뉘면 그것을 소수라고 함.
Mutex m;
bool CalculateRepeatToSelf(int32 selfNum) {
int8 count = 0;
for (int32 i = 2; i <= selfNum; i++) {
if (count > 2)
return false;
if (selfNum % i == 0) {
count++;
}
}
if (count == 1)
return true;
return false;
}
int32 PreCalcuate(int32 order, int32 devision, int32 interval) {
// 1, 10, 100'000
// 2, 10, 100'000
// 3, 10, 100'000
// ...
// 10, 10, 100'000
int32 startNum = (order - 1) * interval + 1;
int32 endNum = order * interval;
int32 count = 0;
for (int32 i = startNum; i <= endNum; i++) {
if (CalculateRepeatToSelf(i))
count++;
}
return count;
}
int main()
{
const int MAX_NUMBER = 1'000'000;
//const int MAX_NUMBER = 10'000; // 1229
//const int MAX_NUMBER = 1'000; // 168
// 1~MAX_NUMBER까지 소수 개수
// 멀티스레드로 병렬로 구해서 덧셈한다.
/*for (int32 i = 1; i <= 20; i++) {
if (CalculateRepeatToSelf(i))
count++;
}
cout << count << endl;*/
// ------------------------
vector<thread> threads;
int32 devision = thread::hardware_concurrency();
int32 interval = MAX_NUMBER / devision + 1;
atomic<int32> totalCount = 0;
for (int32 i = 1; i <= devision; i++) {
threads.push_back(thread([&totalCount, i, devision, interval](){
totalCount+= PreCalcuate(i, devision, interval);
}));
}
for (thread& t : threads) {
t.join();
}
cout << "Total: " << totalCount.load() << endl;
}
답변 1
0
#include <cmath>
#include <vector>
#include <atomic>
#include <thread>
bool IsPrime(int32 num) {
if (num <= 1) return false;
if (num <= 3) return true;
if (num % 2 == 0 || num % 3 == 0) return false;
for (int32 i = 5; i * i <= num; i += 6) {
if (num % i == 0 || num % (i + 2) == 0) return false;
}
return true;
}
int32 CountPrimesInRange(int32 start, int32 end) {
int32 count = 0;
for (int32 i = start; i <= end; i++) {
if (IsPrime(i)) count++;
}
return count;
}
int main() {
const int32 MAX_NUMBER = 1'000'000;
int32 threadCount = std::thread::hardware_concurrency();
std::vector<std::thread> threads;
std::atomic<int32> totalCount = 0;
int32 interval = MAX_NUMBER / threadCount;
for (int32 i = 0; i < threadCount; i++) {
int32 start = i * interval + 1;
int32 end = (i == threadCount - 1) ? MAX_NUMBER : (i + 1) * interval;
threads.emplace_back([start, end, &totalCount]() {
totalCount += CountPrimesInRange(start, end);
});
}
for (auto& t : threads) {
t.join();
}
std::cout << "Total primes up to " << MAX_NUMBER << ": " << totalCount << std::endl;
return 0;
}
Memory Pool에서 오버플로우 질문입니다.
0
63
2
포토폴리오 및 진로 관련하여 고민입니다.
0
112
1
포토폴리오 관련 고민입니다.
0
62
1
실무에서도 alloc, 스마트포인터 등을 구현해서 쓰는지 궁금합니다.
0
82
2
성능 테스트 결과
0
103
2
게임 서버 Stateful, Stateless 진로 고민
0
121
1
WaitOnAddress와 Sleep의 차이 질문
0
83
1
궁금한거 있습니다.
0
82
2
JobTimer 구동 스레드
0
107
2
TryPop() 동작 관련 질문
0
81
1
로드맵 C#서버 C++서버 방향성 질문
0
148
2
스레드 id를 출력할떄 메인스레드 id도 출력되나요?
0
73
1
생명주기를 위한 의도적 복사
0
86
2
락프리의 실무에서 사용 질문
0
139
2
32bit threadID와 16비트 상위 WriteFlag에 대해
0
101
2
mutex와 sleep 차이점
0
117
1
실무에서는 어떠한 코드 스타일을 사용하는지 궁금합니다
0
152
2
Stomp Allocator의 Release함수에 대한 질문입니다.
0
96
1
공부법 관련해서
0
183
2
MakeShared 함수 관련
0
114
1
지금까지 서버코어에서 만든 내용에 대해 궁금한 점이 있어서 질문 드립니다.
0
144
2
운영체제관련 질문입니다
0
131
1
send하려는 데이터 크기가 크면 memcpy에서 문제가 발생할 것 같습니다.
0
117
2
메모리 풀 질문있습니다.
0
124
1





