1

有没有办法让 boost mutex 在任何等待线程上抛出异常?我有一个问题,其中一个对象被删除,但由于软件库的性质,线程可能仍在对象内的互斥锁处等待,并且当互斥锁关闭时抛出一个相当讨厌的异常。我想我可以使用多个互斥计数器,但这可能会导致性能下降。我想要发生的是互斥体在关闭时在等待的任何线程上抛出异常,以便展开堆栈。有没有一种独立于平台的干净方法?

4

1 回答 1

4

这种在销毁时抛出的互斥锁的概念似乎是无害的,但是当需要实现它时,它揭示了您对互斥锁的思考方式的缺陷。

让我们看一些示例代码,以了解这种方法的缺陷。

注意:请不要使用下面的代码,它只会带来无尽的折磨和调试同步问题。

class throwing_mutex
{
private:
    mutex m_;
    condition_variable cv_;
    bool destroyed_;
    bool locked_;

public:
    void lock()
    {
        std::unique_lock<std::mutex> lock(m_);
        cv_.wait(lock, [&]() {return !locked_ || destroyed_;}); // Wait until the mutex is unlocked or destroyed.
        if (destroyed_) throw runtime_error("The exception was terminated while waiting.");
        locked_ = true;
    }

    void unlock()
    {
        std::unique_lock<std::mutex> lock(m_);
        locked_ = false;
        lock.unlock();

        cv_.notify_one();
    }

    ~throwing_mutex()
    {
        std::unique_lock<std::mutex> lock(m_);
        destroyed_ = true;
        lock.unlock();

        cv_.notify_all(); // Let all waiters know we are dead.
    }
};

销毁后,等待的每个人throwing_mutex都会抛出异常。但这开辟了一个相当大的竞争条件。

我们已经处理了每个人都在等待互斥锁的情况——他们会安全地抛出。我们没有处理的是有人正在打电话lock()但还没有到的情况。当他们终于到了可以调用的地步时lock()throwing_mutex已经被销毁了。我们刚刚通过有缺陷的方法引入的错误称为use-after-free。如果我们幸运的话,错误会及早清晰地出现,但有时我们就没有那么幸运了,我们会被折磨数小时或数天。我们的throwing_mutex类不可能解决这个问题,任何需要这样一个类的代码都没有经过深思熟虑的所有权语义。

那么,如果不是通过抛出的互斥锁,我们如何解决这个问题呢?我们修复了互斥锁和被它锁定的对象的生命周期。

据推测,这是互斥锁是一个类的成员。如果是这样的话,这意味着延迟销毁,直到依赖该对象的每个人都完成了它。这是通过使用 a 来传达的shared_ptr。在不深入了解所有权语义的本质的情况下,这是可以回答的最好问题。希望我已经改变了你对问题的思考方式,足以让你偏离原来的计划,转向更可靠的工作。

于 2013-01-13T23:51:58.763 回答