반복적인 스레드 생성 및 삭제 오버헤드를 피하기 위해 C 11에서 스레드 풀을 효율적으로 구현하는 방법은 무엇입니까?

C 11의 스레드 풀링

문제: 스레드를 반복적으로 생성하고 삭제하는 데 비용이 많이 듭니다. 이러한 오버헤드를 발생시키지 않고 작업을 처리하기 위해 영구 스레드 풀을 어떻게 구축할 수 있습니까?

해결책:

ThreadPool 클래스 구현

효율적인 스레드 풀을 만들기 위해 먼저 ThreadPool을 정의합니다. 수업:

class ThreadPool {
public:
    void Start();
    void QueueJob(const std::function<void()>& job);
    void Stop();
    bool busy();

private:
    void ThreadLoop();
    bool should_terminate = false;
    std::mutex queue_mutex;
    std::condition_variable mutex_condition;
    std::vector<std::thread> threads;
    std::queue<std::function<void()>> jobs;
};

1. ThreadPool::Start:

시스템 기능에 따라 고정된 수의 스레드를 생성합니다:

void ThreadPool::Start() {
    const uint32_t num_threads = std::thread::hardware_concurrency();
    for (uint32_t ii = 0; ii < num_threads; ++ii) {
        threads.emplace_back(std::thread(&ThreadPool::ThreadLoop,this))
    }
}

2. ThreadPool::ThreadLoop:

새 작업을 기다리는 끝없는 루프:

void ThreadPool::ThreadLoop() {
    while (true) {
        std::function<void()> job;
        {
            std::unique_lock<std::mutex> lock(queue_mutex);
            mutex_condition.wait(lock, [this] {
                return !jobs.empty() || should_terminate;
            });
            if (should_terminate) {
                return;
            }
            job = jobs.front();
            jobs.pop();
        }
        job();
    }
}

3. ThreadPool::QueueJob:

풀에 새 작업 추가:

void ThreadPool::QueueJob(const std::function<void()>& job) {
    {
        std::unique_lock<std::mutex> lock(queue_mutex);
        jobs.push(job);
    }
    mutex_condition.notify_one();
}

4. ThreadPool::busy:

풀에 활성 작업이 있는지 확인:

bool ThreadPool::busy() {
    bool poolbusy;
    {
        std::unique_lock<std::mutex> lock(queue_mutex);
        poolbusy = !jobs.empty();
    }
    return poolbusy;
}

5. ThreadPool::Stop:

풀을 적절하게 중지합니다.

void ThreadPool::Stop() {
    {
        std::unique_lock<std::mutex> lock(queue_mutex);
        should_terminate = true;
    }
    mutex_condition.notify_all();
    for (std::thread& active_thread : threads) {
        active_thread.join();
    }
    threads.clear();
}

사용법:

thread_pool->QueueJob([] { /* ... */ });

이 구현은 동적을 제공합니다. 스레드가 지속적으로 실행되고 작업이 추가될 때까지 기다리는 스레드 풀입니다.

위 내용은 반복적인 스레드 생성 및 삭제 오버헤드를 피하기 위해 C 11에서 스레드 풀을 효율적으로 구현하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!