내가 좋아하는 정수의 많은 양의 벡터를 정렬하는 빠른 알고리즘을 작성하는 것을 시도하고는 : 159 14 5 97 6 54
정렬
지금까지, 내 프로그램은 벡터로 나누기 같은 MSD에 의해 작은 버킷 :
012,356,741,175,816,278,272,381 :bucket[1]:159 14
bucket[5]:5 54
bucket[6]:6
bucket[9]:97
지금은 가장 중요한 자리 순서 양동이를 정렬하는 재귀 기수 정렬을 사용하는 데 필요한거야 643,210
이 내가 온라인으로 볼 재귀 기수 코드 : 내 코드로이 비트를 구현하는 방법을 모르는
// Sort 'size' number of integers starting at 'input' according to the 'digit'th digit
// For the parameter 'digit', 0 denotes the least significant digit and increases as significance does
void radixSort(int* input, int size, int digit){
if (size == 0)
return;
int[10] buckets; // assuming decimal numbers
// Sort the array in place while keeping track of bucket starting indices.
// If bucket[i] is meant to be empty (no numbers with i at the specified digit),
// then let bucket[i+1] = bucket[i]
for (int i = 0; i < 10; ++i)
{
radixSort(input + buckets[i], buckets[i+1] - buckets[i], digit+1);
}
}
, 나는 [] 위의 코드에 무엇을 버킷에 대해 확실하지 않다 . 아무도 내가 어떤 변화를 만들어야하는지 설명 할 수 있습니까? 다음은 내가 재귀 적으로 사용하지 않기 때문에 잘 수행되지 않는 멀티 쓰레드 코드입니다. 나는 내 코드에이 비트를 구현하는 방법을 모르는
void sort(unsigned int numCores, std::vector<unsigned int> numbersToSort){
// ******************Stage 1****************
// Use multithread to seperate numbers into buckets using the most significant digits
auto smallbuckets = std::vector<std::shared_ptr<std::vector<std::vector<unsigned int>>>>();
std::mutex mutex;
unsigned int workload = numbersToSort.size()/numCores;
std::function<void(unsigned int, unsigned int, unsigned int)> put_small_buckets;
put_small_buckets = [this, &smallbuckets, &mutex]
(unsigned int id, unsigned int start, unsigned int end) {
auto buckets = std::make_shared<std::vector<std::vector<unsigned int>>>(std::vector<std::vector<unsigned int>>());
for (int j = 0; j < 10; ++j) {
buckets->push_back(std::vector<unsigned int>());
}
for (unsigned int i = start; i < end; ++i) {
unsigned int a = numbersToSort[i];
std::string tmp = std::to_string(a);
char c = tmp.at(0);
int ia = c - '0';
(*buckets)[ia].push_back(numbersToSort[i]);
}
std::lock_guard<std::mutex> lock(mutex);
smallbuckets.push_back(buckets);
};
// create a container of threads
std::vector<std::shared_ptr<std::thread>> containerOfThreads;
// create threads and add them to the container.
for (unsigned int i = 0; i < numCores; ++i) {
// start the thread.
unsigned int start = workload * i;
unsigned int end = workload * (i + 1);
if(i == numCores - 1) end = this->numbersToSort.size() ;
containerOfThreads.push_back(std::make_shared<std::thread>(put_small_buckets, i, start, end));
}
// join all the threads back together.
for (auto t : containerOfThreads) t->join();
numbersToSort.clear();
// ******************Stage 2****************
// Put small multithreaded buckets back to the bucket of radix(10)
auto bigbuckets = std::vector<std::shared_ptr<std::vector<unsigned int>>>();
for (int j = 0; j < 10; ++j) {
bigbuckets.push_back(std::make_shared<std::vector<unsigned int>>(std::vector<unsigned int>()));
}
int current_index = 10;
std::function<void()> collect;
collect = [this, &smallbuckets, ¤t_index, &mutex, &collect, &bigbuckets]() {
mutex.lock();
int index = --current_index;
mutex.unlock();
if (index < 0) return;
auto mybucket = bigbuckets[index];
for (auto i = smallbuckets.begin(); i != smallbuckets.end(); ++i) {
mybucket->insert(mybucket->end(), (*(*i))[index].begin(), (*(*i))[index].end());
}
collect();
};
// create a container of threads
containerOfThreads.clear();
// create threads and add them to the container.
for (unsigned int i = 0; i < numCores; ++i) {
containerOfThreads.push_back(std::make_shared<std::thread>(collect));
}
// join all the threads back together.
for (auto t : containerOfThreads) t->join();
// ******************Stage 3****************
// Sort big buckets
for (int j = 0; j < 10; ++j) {
bigbuckets.push_back(std::make_shared<std::vector<unsigned int>>(std::vector<unsigned int>()));
}
std::function<void(unsigned int, unsigned int)> sort_big_buckets;
sort_big_buckets = [this, &bigbuckets, &mutex]
(unsigned int start, unsigned int end) {
unsigned int curr = start;
while(curr < end){
auto mybucket = bigbuckets[curr];
std::sort(mybucket->begin(),mybucket->end(), [](const unsigned int& x, const unsigned int& y){
std::string tmp1 = std::to_string(x);
std::string tmp2 = std::to_string(y);
return lexicographical_compare(tmp1.begin(), tmp1.end(), tmp2.begin(), tmp2.end());
//return aLessB(x,y,0);
});
++curr;
}
};
// create a container of threads
containerOfThreads.clear();
workload = 10/numCores;
// create threads and add them to the container.
for (unsigned int i = 0; i < numCores; ++i) {
// start the thread.
unsigned int start = workload * i;
unsigned int end = workload * (i + 1);
if(i == numCores - 1) end = 10 ;
containerOfThreads.push_back(std::make_shared<std::thread>(sort_big_buckets, start, end));
}
// join all the threads back together.
for (auto t : containerOfThreads) t->join();
// put all elements back to numbersToSort
for (auto i = bigbuckets.begin(); i != bigbuckets.end(); ++i) {
numbersToSort.insert(numbersToSort.end(), (*i)->begin(), (*i)->end());
}
}
관련없는,하지만 벡터를 왜 (나는)'std :: thread'에 대한 공유 포인터를 가지고 있습니까? 그 벡터를 지나치고 있습니까? 스레드에 참여하는 것보다 스레드로 더 많은 작업을 수행 할 수 있습니까? 단순한'std :: thread' 객체의 벡터가 아닌가? 그런 다음'emplace_back'을 사용하여 스레드를 만들 수 있습니다. –
문제에 관해서,'bigbuckets'은 무엇입니까? 'bigbuckets'의 내용은 무엇입니까? [최소, 완전하고 검증 가능한 예제] (http://stackoverflow.com/help/mcve)를 만들어 보여주십시오. –
@Someprogrammerdude 전 벡터를 지나치지 않고 제 텍스트 북 예제 중 하나를 사용하고 있기 때문에 그것을 사용하고 있습니다. 내가 언급 한 방법을 시도해 보겠습니다. 조언 해 주셔서 감사합니다! 또한 필자는 정렬에 접근하려고했던 방법으로 예제를 편집했습니다. – SuperMurloc