线程中如何实现同步？在某些场景条件下需要实现线程同步操作。
1，在进程代码中定义锁和信号：
std::mutex mRequestListLock; // Protect acccess to mRequestList,
std::condition_variable mRequestCond; // signaled when a new request is submitted
2，在线程处理函数中，获取锁和等待信号，实现同步等待。
bool TestThread::threadLoop() {
std::shared_ptr<HalRequest> req;
// TODO: maybe we need to setup a sensor thread to dq/enq v4l frames
// regularly to prevent v4l buffer queue filled with stale buffers
// when app doesn't program a preveiw request
waitForNextRequest(&req);
if (req == nullptr) {
// No new request, wait again
return true;
}
return true;
}
void TestThread::waitForNextRequest(std::shared_ptr<HalRequest>* out) {
if (out == nullptr) {
ALOGE("%s: out is null", __FUNCTION__);
return;
}
std::unique_lock<std::mutex> lk(mRequestListLock); //获取定义好的锁，该函数退出后自动释放该锁
int waitTimes = 0;
std::chrono::milliseconds timeout = std::chrono::milliseconds(kReqWaitTimeoutMs);
auto st = mRequestCond.wait_for(lk, timeout); //等待信号，实现同步。
if (st == std::cv_status::timeout) {
waitTimes++;
if (waitTimes == kReqWaitTimesMax) {
// no new request, return
return;
}
}
//获取同步信号后，实现你的事件处理。
*out = mRequestList.front();
}
3，在你的进程中发送信号通知，实现同步。
Status TestThread::submitRequest(
const std::shared_ptr<HalRequest>& req) {
std::unique_lock<std::mutex> lk(mRequestListLock);//获取锁，实现数据保护和同步
mRequestList.push_back(req);
lk.unlock();//释放锁
mRequestCond.notify_one();//发送信号通知，线程函数在等待该信号后就可以实现后续处理。
return Status::OK;
}
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/182025.html
