3

ここで同期についてまったくn00bの質問があります。私は、反復ごとにプロミスに異なる値「p」を割り当てる「ライター」スレッドを持っています。この値の shared_futures を待ってから処理する「リーダー」スレッドが必要です。私の質問は、future/promise を使用して、リーダー スレッドが「p」の新しい更新を待ってから処理タスクを実行するようにする方法です。各反復？どうもありがとう。

4

3 に答える 3

2

プロミスを空白のプロミスに割り当てることで、プロミスを「リセット」できます。

myPromise = promise< int >();

より完全な例:

promise< int > myPromise;

void writer()
{
    for( int i = 0; i < 10; ++i )
    {
        cout << "Setting promise.\n";
        myPromise.set_value( i );

        myPromise = promise< int >{};       // Reset the promise.

        cout << "Waiting to set again...\n";
        this_thread::sleep_for( chrono::seconds( 1 ));
    }
}

void reader()
{
    int result;
    do
    {
        auto myFuture = myPromise.get_future();
        cout << "Waiting to receive result...\n";
        result = myFuture.get();
        cout << "Received " << result << ".\n";
    } while( result < 9 );
}

int main()
{
    std::thread write( writer );
    std::thread read( reader );

    write.join();
    read.join();

    return 0;
}

ただし、このアプローチの問題点は、2 つのスレッド間の同期によってpromise::set_value()、リーダーが を呼び出す間にライターが複数回呼び出されたり、Promise のリセット中に呼び出されfuture::get()たりする可能性があることです。future::get()これらの問題は注意して回避できます (たとえば、呼び出しの間に適切なスリープを行うなど) が、論理的に正しい同時実行性ではなく、ハッキングと当て推量の領域に陥ります。

そのため、Promise を新しい Promise に割り当てることでリセットすることは可能ですが、そうすると、より広範な同期の問題が発生する傾向があります。

于 2015-02-25T17:09:22.547 に答える