[비동기] promise, future 사용 예제 및 예외처리 상황

promise, future를 사용한 예제

promise와 future를 사용하면 이 둘 간에 채널이 생성된다.
따라서 이 채널은 하나만 유지되어야 한다.
쓰레드로 인자로 promise를 넘길때, 단순히 promise를 넘기면 copy한다는 뜻이며 이는 1:1의 채널 관계가 어긋남을 뜻한다.
그래서 std::move를 이용하여 r-value로 인자를 넘겨준다.

#include <iostream>
#include <future>
#include <thread>

using namespace std::chrono_literals;
void fn(std::promise<int> prm) {

    std::this_thread::sleep_for(2s);
    prm.set_value(33);
}

int main() {
    std::promise<int> prm;
    std::future<int> fut = prm.get_future();

    std::thread t(fn, std::move(prm));

    int num = fut.get();
    std::cout << "num : " << num << std::endl;

    t.join();
}

결과값

num : 33

예외 발생 상황

set_value와 set_exception을 동시에 사용할 수는 없다.
thread에서는 예외처리를 하기가 힘들다는 이슈가 있으나 promise, future로는 이를 핸들링 할 수 있음.

void fn(std::promise<int> prm) {

    std::this_thread::sleep_for(2s);
    try {
        throw std::runtime_error("yllee error");
        prm.set_value(33);
    }
    catch (...) {
        prm.set_exception(std::current_exception());
    }
    //set_value과 set_exception을 동시에 사용해서는 안된다.  
}

int main() {
    std::promise<int> prm;
    std::future<int> fut = prm.get_future();

    std::thread t(fn, std::move(prm));

    while (fut.wait_for(0.2s) != std::future_status::ready)
    {
        std::cout << "Doing another things... 0.2sec.... " << std::endl;
    }
    try {
        int num = fut.get();
        std::cout << "num : " << num << std::endl;
    }
    catch (const std::exception& e) {
        std::cout << e.what() << std::endl;
    }

    t.detach();
}

결과값