Threading.h

Go to the documentation of this file.

 
#pragma once
 
#include <functional>
#include <thread>
#include <vector>
 
namespace Gorgon {
 
    namespace Threading {
        
 
        inline void RunAsync(std::function<void()> fn) {
            std::thread t(fn);
            t.detach();
        }
        
        inline void RunInParallel(std::function<void(int, int)> fn, unsigned threads=0) {
            std::vector<std::thread> thrds;
 
            if(threads==0) threads=std::thread::hardware_concurrency();
            
            for(int id=0;id<threads;id++) {
                thrds.emplace_back(fn, id, threads);
            }
            
            for(int id=0;id<threads;id++) {
                thrds[id].join();
            }
        }
    }
    
}