gpt4 book ai didi

c++ - 将数据从调用者线程传递到另一个 boost::thread 中的方法

转载 作者:塔克拉玛干 更新时间:2023-11-03 06:50:30 26 4
gpt4 key购买 nike

我有一个关于 C++ 并发(使用 Boost 线程)的菜鸟问题,我还没有找到明确的答案。我有一个工作类在一个单独的线程中运行。我在只编程一次。这个工作人员是“懒惰的”,只有当它从调用线程接收到数据时才进行一些数据编码。在工作人员中我有一个公共(public)方法:

void PushFrame(byte* data);

它将数据推送到 std::stack 成员变量,以便每次将新数据对象推送到那里时工作人员都可以访问它。

我不明白的是这样的交互一般是怎么做的?我可以只从调用者线程调用 PushFrame() 并传递参数吗?还是我必须以某种特殊方式访问 worker 中的方法?

最佳答案

通常您使用生产者-消费者队列来完成此类工作。

每当工作线程用完工作时,他就 wait() 启动 boost::condition_variable,该变量受相同的 boost::mutex 作为保存工作线程数据的堆栈(您可能想在此处使用队列来尽量减少不公平工作调度的风险)。

您的 PushFrame() 函数现在会在该条件变量上调用 notify_one(),每当它向堆栈中插入新数据时。这样,工作线程将真正休眠(即操作系统调度程序可能不会给它任何时间片),直到真正有工作要完成。

这里最容易出错的是保护堆栈和 condition_variable 的互斥量的锁定。除了避免数据结构上的竞争之外,您还需要注意 condition_variable 不会错过通知调用,因此可能会在实际有更多工作可用时陷入等待。

class Worker {
void PushFrame(byte* data)
{
boost::lock_guard<boost::mutex> lk(m_mutex);
// push the data
// ...
m_data_cond.notify_one();
}
void DoWork()
{
while(!done) {
boost::unique_lock<boost::mutex> lk(m_mutex);

// we need a loop here as wait() may return spuriously
while(is_out_of_work()) {
// wait() will release the mutex and suspend the thread
m_data_cond.wait(lk);
// upon returning from wait() the mutex will be locked again
}

// do work from the queue
// ...
}
}
boost::mutex m_mutex;
boost::condition_variable m_data_cond;
[...]
};

关于c++ - 将数据从调用者线程传递到另一个 boost::thread 中的方法,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/16669959/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com