c++ - 我应该按什么顺序发送 callback() 并通知服务员？

Question

我有一个类，通过它可以异步提供一些服务(也可以同步进行相同的调用)。当被请求时，此类的对象(比如运算符)在不同的线程中启动操作。其他对象可以注册到 operator 对象的通知，以便在操作结束时调用此对象上的 OperationEnded() 方法。其他对象也可以通过在运算符对象上调用 Wait() 来等待此操作的完成。

运行结束时的代码大致如下:

_opEndedMutex.lock();
_thereIsOngoingOp = false;
_opEndedCondition.notify_all();
_opEndedMutex.unlock();

//no more call after notification
m_spNotificationManager->OperationEnded();

wait()函数如下:

boost::unique_lock<boost::mutex> lock(_opEndedMutex);
while(_thereIsOngoingOp)
{
    _opEndedCondition.wait(_opEndedMutex);
}

问题是关于资源管理的。这是一个 C++ 类，因此当检测到操作结束时，此类的用户可以删除运算符对象(如果有任何事件操作，析构函数将等待完成)。操作的结束可以通过等待或接受通知来检测。因此，如果我先调用 _opEndedCondition.notify_all() 并且用户删除了运算符对象，它可能会在尝试调用 OperationEnded() 时崩溃，因为 m_spNotificationManager 已被删除。如果选择先调用 OperationEnded() 并且用户在此调用期间删除了运算符对象，则它可能会在尝试访问 _opEndedMutex、_thereIsOngoingOp 和 _opEndedCondition 时崩溃。

作为解决方案，我想到的第一件事是使用新的互斥锁来保护这两个调用。这看起来不太好，因为我无法预见如果引入新的互斥锁以及如果在 OperationEnded() 通知中用户同步启动新操作会发生什么。我也不确定如何在 wait() 方法中使用新的互斥量。

note1:这个API既有我们自己公司的应用，也有其他公司的应用。所以我无法摆脱任何一种同步机制。

note2:我修改了原代码、变量名和方法名，可能有错别字，但思路应该清晰。

编辑1:

算子对象保存在一个通过工厂生成的共享库中，然后通过一个接口(interface)暴露给外界。 因此，运算符对象的典型生命周期为:

IOperator * op = factory:getNewOperator();
//perform operations with op
op->Release() //this one goes and deletes the op object

另请注意，运算符对象是可重用的。客户端代码可以使一个新的运算符对象多次使用它并在最后删除它。

Answer 1

你有几个解决办法:

• 您可以从 std::enable_shared_from_this 中专门化您的操作对象.这将意味着在客户端代码中，您不再删除该对象，而是将一个 std::shared_ptr 设置为 nullptr，并且不关心该对象何时被实际删除。

• 您可以在计时器延迟时实现有限的垃圾收集:当您在客户端代码中收到 OperationEnded() 通知时，您获取指针并将其放入队列中，同时添加对象时的时间戳。然后，队列将有一个事件对象，该对象在计时器上唤醒，获取当前时间，如果时间戳(比方说)至少比当前时间早五秒，则将其删除。

• 您可以使用 object pool 分配和取消分配操作类.当一个对象不再被使用时，它实际上并没有被删除，而是作为一个空闲(回收)对象放置在池中。在您完成处理后，当池被销毁时，该对象实际上会被删除。

• 您可以为您的对象创建一个生命周期管理器，它会删除您的操作对象，然后发送通知。

• 您可以让您的“OperationEnded”函数调用 delete this; 结束；然后，您将实现客户端代码以在收到通知时简单地将指针设置为 NULL；虽然这样的解决方案很脆弱，但在您的实现中，这可能只是将问题转移到另一段代码。

• 最后，您可以实现所有这些的自定义组合。