如何在抛出异常时处理共享数据

Z时代
2024-01-10
分类：问答

当多个线程使用共享数据时，如何在抛出异常时正确处理数据的销毁？如何在抛出异常时处理共享数据

我正在研究一个应用程序，我希望一个进程在等待从另一个进程通过网络发送的结果的同时进行工作。我实现创建一个线程等待结果一类，像下面的（实际的代码太大，张贴在这里，所以这是一个小例子）：

class Notifier { 
    public: 
    Notifier(Client* _client) : value(-1), client(_client) { 
     listener = boost::thread(&Notifer::Listen, this); 
    } 
    void Listen() { 
     try { 
     int rec = client->Receive(); //blocking call to receive data over a socket 
     boost::scoped_lock sl(mutex); 
     value = rec; 
     } catch (...) { 
     cout << "Exception thrown in listener" << endl; 
     } 
    } 
    int Get() { 
     boost::mutex::scoped_lock sl(mutex); 
     return value; 
    } 
    private: 
    int value; 
    boost::mutex; 
    boost::thread listener; 
    Client* client; 
} 
int main() { 
    Client client; //initialize client, connect, etc. 
    Notifier n(client); 
    while(n.Get() < 0) { 
    // do work 
    cout << "Waiting for data" << endl; 
    sleep(1); 
    } 
}

这工作对我很好，直到我添加异常处理：

int main() { 
    try { 
    Client client; //initialize client, connect, etc. 
    Notifier n(client); 
    while(n.Get() < 0) { 
    // do work 
    cout << "Waiting for data" << endl; 
    sleep(1); 
    throw exception(); 
    } 
    } catch(...) { 
    cout << "Exception thrown in main" << endl; 
    } 
    return 0; 
}