summaryrefslogtreecommitdiffstats
path: root/src/common/detached_tasks.cpp
blob: a347d9e02a95fc0b6b54be4c17b496f915c71f2b (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
// Copyright 2018 Citra Emulator Project
// Licensed under GPLv2 or any later version
// Refer to the license.txt file included.

#include <thread>
#include "common/assert.h"
#include "common/detached_tasks.h"

namespace Common {

DetachedTasks* DetachedTasks::instance = nullptr;

DetachedTasks::DetachedTasks() {
    ASSERT(instance == nullptr);
    instance = this;
}

void DetachedTasks::WaitForAllTasks() {
    std::unique_lock<std::mutex> lock(mutex);
    cv.wait(lock, [this]() { return count == 0; });
}

DetachedTasks::~DetachedTasks() {
    std::unique_lock<std::mutex> lock(mutex);
    ASSERT(count == 0);
    instance = nullptr;
}

void DetachedTasks::AddTask(std::function<void()> task) {
    std::unique_lock<std::mutex> lock(instance->mutex);
    ++instance->count;
    std::thread([task{std::move(task)}]() {
        task();
        std::unique_lock<std::mutex> lock(instance->mutex);
        --instance->count;
        std::notify_all_at_thread_exit(instance->cv, std::move(lock));
    })
        .detach();
}

} // namespace Common