仓库源文，站点原文

layout: post title: c++11 promise和future date: 2019-08-24 11:16 +0800

categories: C/C++

使用promise，編譯時需要 -std=c++11 -pthread 才會動。

就像其他語言一樣，promise主要用來做異步流程控制。

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

using namespace std;

void runner(promise<int> *p) {
    cout << "do some io task" << endl;
    p->set_value(3);
}

int main() {
    promise<int> p;
    std::thread t(runner, &p);

    int ret = p.get_future().get(); // Wait p.set_value()
    cout << ret << endl;

    t.join();

    return 0;
}

do some io task
3

比較常使用到promise的狀況是跟其他library接的時候，對方透過callback或listener，

將執行完成的結果回傳，這時候就可以包裝變成同步的寫法。

#include <future>
#include <thread>
#include <string>
#include <exception>
#include <iostream>

using namespace std;

// Someone provides Downloader class.
class Downloader {
    public:
        void SetCallback(function<void(int,string)> cb) { cb_ = cb; }
        void Download(string url) {
            thread([=] () {
                    cout << "downloading: " << url << endl;
                    cb_(0, "ok");
            }).detach();
        }
    private:
        function<void(int,string)> cb_;
};

void download_callback(promise<string> *p, int status, string data) {
    if(status != 0) {
        p->set_exception(make_exception_ptr(runtime_error("download failed")));
    } else {
        p->set_value(data);
    }
}

int main() {
    promise<string> p;

    Downloader d;
    d.SetCallback(bind(download_callback, &p,
        placeholders::_1, placeholders::_2));
    d.Download("127.0.0.1");

    try {
        string ret = p.get_future().get();
        cout << ret << endl;
    } catch(exception &e) {
        cout << "future: " << e.what() << endl;
    }

    return 0;
}

downloading: 127.0.0.1
ok

promise也有一些限制：它只能被使用一次，每次使用後就要宣告新的promise object。

如果使用condition variable的話就可以重複使用 wait() 和 notify_one()，

但是必須自己處理value的回傳。換句話說，每次呼叫function都需要一個獨立的promise object。

如果上面的Download()連續呼叫兩次，程式就會發生錯誤。

所以Downloader內部還需要一個mutex防止被重複呼叫，才能正確運作。

一個比較好的寫法是從Downloader直接提供future物件給caller等待。

#include <future>
#include <unistd.h>
#include <thread>
#include <string>
#include <exception>
#include <iostream>
#include <chrono>

using namespace std;

class Downloader {
    public:
        future<string> Download(string url) {
            auto p = make_shared<promise<string>>();
            thread([=] () {
                    cout << "downloading: " << url << endl;
                    sleep(1);
                    download_callback(p.get(), 0, "ok");
            }).detach();
            return p->get_future();
        }
    private:
        void download_callback(promise<string> *p, int status, string data) {
            if(status != 0) {
                p->set_exception(make_exception_ptr(runtime_error("download failed")));
            } else {
                p->set_value(data);
            }
        }
};


int main() {
    Downloader d;

    try {
        auto now = time(NULL);
        auto d1 = d.Download("127.0.0.1");
        auto d2 = d.Download("127.0.0.2");
        auto d3 = d.Download("127.0.0.3");
        cout << d1.get() << endl;
        cout << d2.get() << endl;
        cout << d3.get() << endl;
        cout << time(NULL) - now << endl;
    } catch(exception &e) {
        cout << "future: " << e.what() << endl;
    }

    return 0;
}

downloading: 127.0.0.3
downloading: 127.0.0.2
downloading: 127.0.0.1
ok
ok
ok
1