当前位置:首页 > 力扣 > 力扣1116题:用C++实现多线程交替输出零、偶数、奇数

力扣1116题:用C++实现多线程交替输出零、偶数、奇数

4个月前 (07-29)

力扣1116题:用C++实现多线程交替输出零、偶数、奇数 力扣题解 多线程 C++ 互斥锁 偶数 奇数 第1张

一、题目解读

力扣1116题要求设计一个类,实现三个线程交替输出数字:一个线程输出连续的0,一个线程输出连续的偶数,另一个线程输出连续的奇数。输入参数n为总输出次数(每个线程各输出n次),输出需严格按照0-偶数-奇数的顺序循环,直至所有线程完成指定次数。题目核心在于多线程间的精确协作与同步控制。

二、解题思路

通过条件变量与互斥锁实现线程间的同步。关键在于设计状态变量next_type(标记下一个输出类型)与count(全局计数),结合cv.wait()的谓词条件判断线程唤醒时机。通过notify_all()确保所有等待线程重新检查条件,避免死锁或饥饿问题。

三、步骤解析

1. 初始化:构造函数中初始化n、count=1、zero_flag=true、next_type=0,确保首个输出为0。

2. zero线程:循环n次,每次等待next_type=0,输出0后更新next_type为后续类型(奇数或偶数),并通知其他线程。

3. even/odd线程:循环直至count > n或获取对应类型权限。通过谓词条件判断是否激活(如偶数线程等待next_type=2或结束条件),输出并更新状态,最后通知所有线程。

4. 同步逻辑:利用unique_lock自动管理锁,条件变量结合谓词避免虚假唤醒,notify_all()保证所有线程重新评估条件。

四、代码与注释

class ZeroEvenOdd {
private:
    int n;          // 总输出次数
    int count;      // 全局计数
    bool zero_flag; // 初始标记
    int next_type;  // 0: zero, 1: odd, 2: even
    std::mutex mtx; // 互斥锁
    std::condition_variable cv; // 条件变量

public:
    ZeroEvenOdd(int n) {
        this->n = n;       // 初始化参数
        count = 1;         // 从1开始计数
        zero_flag = true;  // 首个线程为0
        next_type = 0;     // 初始输出类型
    }

    void zero(function<void(int)> printNumber) {
        for (int i = 0; i < n; ++i) {  // 循环n次
            unique_lock<mutex> lock(mtx); // 加锁
            cv.wait(lock, [this]{ return next_type == 0; }); // 等待类型为0
            printNumber(0);              // 输出0
            next_type = (count % 2 == 1)? 1 : 2; // 根据count奇偶决定后续类型
            cv.notify_all();              // 唤醒所有线程
        }
    }

    void even(function<void(int)> printNumber) {
        while (true) {
            unique_lock<mutex> lock(mtx);
            cv.wait(lock, [this]{ 
                return next_type == 2 || count > n;  // 等待类型为2或结束条件
            });
            if (count > n) break;              // 结束循环
            printNumber(count++);               // 输出偶数并递增计数
            next_type = 0;                      // 重置类型
            cv.notify_all();
        }
    }

    void odd(function<void(int)> printNumber) {
        while (true) {
            unique_lock<mutex> lock(mtx);
            cv.wait(lock, [this]{ 
                return next_type == 1 || count > n;  
            });
            if (count > n) break;
            printNumber(count++);
            next_type = 0;
            cv.notify_all();
        }
    }
};

五、总结

该解法巧妙利用条件变量与互斥锁实现线程间的精确协作,通过状态变量动态切换输出类型,避免复杂的条件判断。核心优势在于:

1. 清晰的状态转移逻辑(next_type与count的协同);

2. 谓词条件防止虚假唤醒,提升效率;

3. notify_all()确保所有线程响应,避免饥饿问题。

对多线程同步控制与力扣算法优化具有参考价值,适用于需要高并发协作的场景。


原创内容 转载请注明出处

分享给朋友:

相关文章

力扣第1984题精解:如何通过排序将时间复杂度优化到O(n log n)?

力扣第1984题精解:如何通过排序将时间复杂度优化到O(n log n)?

题目解读给定一个整数数组和一个整数 k,需要找到所有大小为 k 的子数组中最大值与最小值的差值的最小值。例如,数组 [9,4,1,7] 中若 ...

力扣53题:贪心策略与动态规划的完美联姻 三行代码映射算法精髓

力扣53题:贪心策略与动态规划的完美联姻 三行代码映射算法精髓

题目理解在数字的海洋中寻找最具价值的珍珠链:当我们面对一个可能包含正负数的数组时,寻找连续子数组的和最大值就像在波动的股票曲线中捕捉最佳投资时段。问题的核心在于如何处理可能降低总和的负值元素——是忍痛...

力扣1221:一次扫描解决分割平衡字符串 时间O(n)空间O(1)

力扣1221:一次扫描解决分割平衡字符串 时间O(n)空间O(1)

题目重解给定一个仅包含'L'和'R'的字符串,要求将其分割成尽可能多的子串,且每个子串中'L'和'R'的数量相等。例如输入"R...

牛客DP41精讲:当背包必须装满时,你的状态转移方程该如何调整?

牛客DP41精讲:当背包必须装满时,你的状态转移方程该如何调整?

题目重解我们面对一个经典背包问题的变体:给定n个物品,每个物品有重量w和价值v,背包容量为V。需要回答两个问题:1) 普通情况下能获得的最大价值;2) 必须恰好装满背包时的最大价值(若无法装满则输出0...

力扣540题:线性扫描法如何高效定位唯一数

力扣540题:线性扫描法如何高效定位唯一数

题目重解一个严格递增的有序数组中,除某个元素外,其余每个元素均出现两次。这个看似简单的条件背后隐藏着巧妙的规律——单一元素会打破数组的"成对对称性"。题目要求以O(log n)时间...

手搓顺序表类代码注释与详解:从零实现动态数组(新手教程)

一、简介和特点顺序表(Sequential List)是数据结构中基础的一种线性表,其特点是将数据元素存储在连续的内存空间中。通过数组实现,支持随机访问(即通过索引直接访问元素),适用于频繁随机读取的...

发表评论

访客

看不清,换一张

◎欢迎参与讨论,请在这里发表您的看法和观点。