我有两个线程，一个线程应该接收和处理来自另一个线程的请求。第二种是同步传输请求和接收响应。我尝试了以下方案:成对队列(值(value)， promise )。第一个线程创建一个 promise 并将其插入同步队列并等待 future.get()

问题是有时线程卡在 future.get() 上，但是当我暂停程序执行并继续时它再次正常工作。这个stucks具有随机​​性。

FutureQueue.h

#ifndef FutureQueue_h
#define FutureQueue_h

#include <queue>
#include <future>
#include <thread>
#include <mutex>
#include <condition_variable>

template <typename T, typename R>
class Work{
public:
    Work(){

    }
    Work(T value, std::promise<R>* promise){
        m_value = value;
        m_p_promise = promise;
    }
    std::promise<R>* m_p_promise;
    T m_value;
public:
    T getValue(){
        return m_value;
    }
    void setResult(R result){
        m_p_promise->set_value(result);
    }
};


template <typename T, typename R>
class FutureQueue
{
public:
    Work<T,R> getWork(){
        auto p = pop();
        return Work<T,R>(p.first,p.second);
    }
    R execute(T value)
    {
        std::promise<R> promise = std::promise<R>();
        std::future<R> f = promise.get_future();
        auto p = std::pair<T, std::promise<R>*>(value, &promise);
        push(p);
        return f.get();
    }
    private:
    std::pair<T,std::promise<R>*> pop(){
        std::unique_lock<std::mutex> mlock(mutex_);
        while (queue_.empty())
        {
            cond_.wait(mlock);
        }
        auto item = queue_.front();
        queue_.pop();
        return item;
    }
    void push(const std::pair<T,std::promise<R>*>& item){
        std::unique_lock<std::mutex> mlock(mutex_);
        queue_.push(item);
        mlock.unlock();
        cond_.notify_one();
    }
    std::queue<std::pair<T,std::promise<R>*>> queue_;
    std::mutex mutex_;
    std::condition_variable cond_;
};

#endif

main.cpp

#include <iostream>
#include <thread>

#include "FutureQueue.h"

using namespace std;

atomic<bool> quit;
FutureQueue<int, int> mQueue;

void consumer(){
    Work<int,int> work;
    while(true){
        work = mQueue.getWork();
        if (quit){
            break;
        }
        int value = work.getValue()+100;
        work.setResult(value);
    }
    work.setResult(0);
}

int main(int argc, const char * argv[]) {
    quit = false;
    thread thread(consumer);
    // test 2
    for (int i=0;i<100000;i++){
        int value = mQueue.execute(i);
        cout << "input " << i <<" execute result " <<  value << endl;
    }
    quit = true;
    mQueue.execute(-1);
    thread.join();
    return 0;
}

我不知道这段代码有什么问题，也许你可以提出更好的解决方案。谢谢

更新

Stucks 只发生在 os x with Apple LLVM version 6.0

在OS X和Linux的gcc下以及Windows的Visual studio下都没有问题

最佳答案

有两个线程，A跟

for (int i=0;i<100000;i++){
    int value = mQueue.execute(i);
    cout << "input " << i <<" execute result " <<  value << endl;
}
quit = true;
mQueue.execute(-1);

B 与

thread thread(consumer);

你期望 B 先运行，然后卡住，因为

   while (queue_.empty())
    {
        cond_.wait(mlock);
    }

B 将继续运行，直到 A 运行以下代码

    cond_.notify_one();

通常会没事的。但是如果A先fun“cond.notify_one()”，B调用“con_.wait(mlock)”，B就会永远卡住。

关于c++ - std::future.get() 有时卡在 os x 中，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/34370995/