惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

酷 壳 – CoolShell
酷 壳 – CoolShell
H
Hacker News: Front Page
P
Palo Alto Networks Blog
T
ThreatConnect
Apple Machine Learning Research
Apple Machine Learning Research
博客园_首页
T
True Tiger Recordings
P
Privacy & Cybersecurity Law Blog
B
Blog
IT之家
IT之家
Last Week in AI
Last Week in AI
F
Full Disclosure
Hacker News: Ask HN
Hacker News: Ask HN
C
Comments on: Blog
Microsoft Azure Blog
Microsoft Azure Blog
C
Cybersecurity and Infrastructure Security Agency CISA
Microsoft Security Blog
Microsoft Security Blog
博客园 - 【当耐特】
N
News and Events Feed by Topic
NISL@THU
NISL@THU
腾讯CDC
雷峰网
雷峰网
Security Latest
Security Latest
李成银的技术随笔
M
Microsoft Research Blog - Microsoft Research
L
LangChain Blog
L
Lohrmann on Cybersecurity
cs.CL updates on arXiv.org
cs.CL updates on arXiv.org
C
Check Point Blog
Y
Y Combinator Blog
Recent Announcements
Recent Announcements
博客园 - Franky
N
News | PayPal Newsroom
V
V2EX
A
About on SuperTechFans
The Register - Security
The Register - Security
月光博客
月光博客
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
Google Online Security Blog
Google Online Security Blog
MyScale Blog
MyScale Blog
Cisco Talos Blog
Cisco Talos Blog
Vercel News
Vercel News
WordPress大学
WordPress大学
C
Cyber Attacks, Cyber Crime and Cyber Security
The Hacker News
The Hacker News
IntelliJ IDEA : IntelliJ IDEA – the Leading IDE for Professional Development in Java and Kotlin | The JetBrains Blog
IntelliJ IDEA : IntelliJ IDEA – the Leading IDE for Professional Development in Java and Kotlin | The JetBrains Blog
爱范儿
爱范儿
A
Arctic Wolf
L
LINUX DO - 最新话题
freeCodeCamp Programming Tutorials: Python, JavaScript, Git & More

博客园 - 流逝的轻风

3D点云到2D点云投影图像具体方法 - 流逝的轻风 单目相机 MATLAB 参数标定详解 nmcli修改ip地址 nginx 交叉编译报错问题解决(转) 图片转视频并推流源码,已通过测试 Hadoop的安装,图文并茂的安装过程 ffmpeg重新编码示例 编译ffmpeg以支持rtmp, librtmp not found问题 瑞芯微rk3399实现硬编硬解编译rkmpp到ffmpeg Openc4.8QT中编译异常处理 yolov8模型转onnx MIPS编译opencv-自用 docker启动ubuntu,并映射端口 mips交叉编译相关库文件,主要做以后参考 OPENSSL1.1交叉编译编译异常处理 mips交叉编译ffmpeg 关于/proc/id/status中内容的描述 Linux GPIO控制方法 A7-NXP-6G2C修改分驱大小
线程占用等待释放解决方案
流逝的轻风 · 2025-03-20 · via 博客园 - 流逝的轻风

线程占用等待释放解决方案

#include <iostream>
#include <thread>
#include <unistd.h>
#include <mutex>
#include <condition_variable>


/**
 * 览辉视频封装接口
 */
class LHAVObject {
private:
    bool m_bIsRelease = false;
public:
    std::mutex m_oWorkingMutex;
    std::condition_variable m_nWaitWorkingCV; //推流消费条件锁
    int m_bIsWorking = 0;

public:

    /**
     * 释放标记
     * @return
     */
    bool IsRelease() { return m_bIsRelease; }

    /**
     * 释放资源
     * @return
     */
    bool Release() { return true; }

    /**
     * 验证释放
     */
    bool ValidRelease() {
        std::unique_lock<std::mutex> lock(this->m_oWorkingMutex); //释放标记锁
        this->m_bIsRelease = true; //标记释放
        for (int i = 0; i <= 20 && this->m_bIsWorking >= 1; i++) { //检测是否有工作正在进行
            if (i >= 20) {
                this->m_bIsRelease = false; //释放失败
                return false;
            }
            m_nWaitWorkingCV.wait(lock);
        }
        return true;
    }

};

class FunMarker {
public:
    explicit FunMarker(LHAVObject *o) {
        this->m_pObject = o;
        if (this->m_pObject == nullptr) { return; }
        std::unique_lock<std::mutex> lock(this->m_pObject->m_oWorkingMutex); //释放标记锁
        this->m_pObject->m_bIsWorking++;
    }

    virtual ~FunMarker() {
        if (this->m_pObject == nullptr) { return; }
        std::unique_lock<std::mutex> lock(this->m_pObject->m_oWorkingMutex); //释放标记锁
        this->m_pObject->m_bIsWorking--;
        this->m_pObject->m_nWaitWorkingCV.notify_all();
    }

private:
    LHAVObject *m_pObject;

};

class Student : public LHAVObject {
public:
    bool isWorking = false;
public:
    void Hello() {
        FunMarker maker(this);
        isWorking = true;
        sleep(20);
        std::cout << "hello" << std::endl;
        isWorking = false;
    }

};

int main() {
    std::cout << "Hello, World!" << std::endl;

    auto *b = new Student();

    std::thread test([](Student *c) {
        c->Hello();
    }, b);
    test.detach();

    if(!b->ValidRelease()){
        return 0;
    }

    b->Release();
    delete b;

    std::cout << "Hello, World!3" << std::endl;
    return 0;
}

posted @ 2025-03-20 15:24  流逝的轻风  阅读(35)  评论()    收藏  举报