C++ 11에서 반복적으로 스레드 세트를 생성 하시겠습니까?

Question

큰 매트릭스에 항목을 채우는 기능이 있습니다. 계산이 독립적이므로 매트릭스의 덩어리가 별도의 스레드로 처리 될 수 있도록 std::thread을 악용하려고합니다.

매트릭스를 n 청크로 나누는 대신에 n이 동시에 실행할 수있는 최대 스레드 수의 한계 인 경우 기존 스레드가있을 때 새 스레드를 생성 할 수 있도록 더 미세한 청크를 만들고 싶습니다. 끝마친. (계산 시간이 각기 다른 엔트리에 따라 크게 다를 것이기 때문에 행렬을 똑같이 나누는 것은 여기서는별로 효율적이지 않을 것입니다.)

std :: thread의 개념은 무엇입니까? 이? (내가 그러한 종류의 산란을 위해 어떻게 악용 될 수 있는지 명확히 알지 못했지만, async과 condition_variables을 보았습니다.) 일부 의사 코드는 크게 도움이 될 것입니다!

Answer 1

스레드 작성시 OS 스케줄러에 세금이 부과되는 이유 & 파괴? (이러한 작업은 비용이 많이 듭니다.) 대신 스레드가 더 많이 작동하도록하십시오.

편집 : 동일한 청크로 작업을 분할하고 싶지 않으면 가장 좋은 해결책은 실제로 스레드 풀입니다. 참고로 thread_pool library in the works for C++14이 있습니다.

다음은 동등한 청크로 작업을 나눌 수 있다고 가정하므로 질문에 정확하게 적용되지 않습니다. 편집 끝. @Igor Tandetnik이 코멘트에 알 수 있듯이

struct matrix 
{ 
    int nrows, ncols; 
    // assuming row-based processing; adjust for column-based processing 
    void fill_rows(int first, int last); 
}; 

int num_threads = std::thread::hardware_concurrency(); 
std::vector<std::thread> threads(num_threads); 

matrix m; // must be initialized... 
// here - every thread will process as many rows as needed 
int nrows_per_thread = m.nrows/num_threads; 
for(int i = 0; i != num_threads; ++i) 
{ 
    // thread i will process these rows: 
    int first = i * nrows_per_thread; 
    int last = first + nrows_per_thread; 
    // last thread gets remaining rows 
    last += (i == num_threads - 1) ? m.nrows % nrows_per_thread : 0; 
    threads[i] = std::move(std::thread([&m,first,last]{ 
       m.fill_rows(first,last); })) 
} 

for(int i = 0; i != num_threads; ++i) 
{ 
    threads[i].join(); 
} 

이 당신이 매우 자주 할 작업이 경우, 작업자 풀을 사용합니다. 일회성으로 인해 문제가되지 않습니다.