C++ 동시 프로그래밍의 이론 및 실제 탐구

#include <iostream>
#include <vector>
#include <thread>
#include <mutex>
#include <condition_variable>

using namespace std;

// 图像块结构体
struct ImageBlock {
    int start_row;  // 块的起始行
    int start_col;  // 块的起始列
    int width;      // 块的宽度
    int height;     // 块的高度
};

// 共享变量保护
mutex m;
condition_variable cv;

// 是否已处理完所有块
bool done = false;

// 图片处理函数
void processImageBlock(ImageBlock block) {
    // ... 实际的图像处理操作 ...
}

// 线程处理函数
void threadFunc(vector<ImageBlock>& blocks) {
    while (!done) {
        // 获取一个未处理的块
        unique_lock<mutex> lk(m);
        ImageBlock block;
        for (auto& b : blocks) {
            if (!b.processed) {
                block = b;
                b.processed = true;
                break;
            }
        }
        // 如果没有未处理的块，则等待
        if (!block.processed) {
            cv.wait(lk);
        }
        // 对块进行处理
        processImageBlock(block);
    }
}

int main() {
    // 划分图像为块
    vector<ImageBlock> blocks;
    // ... 省略分割图像的代码 ...

    // 创建线程池
    vector<thread> threads;
    for (int i = 0; i < 4; i++) {
        threads.emplace_back(threadFunc, ref(blocks));
    }

    // 等待所有线程完成
    {
        unique_lock<mutex> lk(m);
        done = true;
        cv.notify_all();
    }
    for (auto& t : threads) {
        t.join();
    }

    return 0;
}