c++ seekg在多线程环境下如何使用 - 问答

在C++中，seekg()函数用于设置文件读取指针的位置

使用互斥锁（mutex）：

互斥锁可以确保在同一时刻只有一个线程访问文件。你可以使用C++标准库中的std::mutex来实现这个功能。

#include <iostream>
#include <fstream>
#include <thread>
#include <mutex>

std::mutex mtx; // 全局互斥锁

void readFile(const std::string& filename, long long offset) {
    std::lock_guard<std::mutex> lock(mtx); // 自动加锁

    std::ifstream file(filename, std::ios::binary);
    if (!file) {
        std::cerr << "Error opening file: " << filename << std::endl;
        return;
    }

    file.seekg(offset, std::ios::beg); // 设置文件指针位置
    // ... 在这里进行文件读取操作 ...
}

int main() {
    std::thread t1(readFile, "file1.txt", 0);
    std::thread t2(readFile, "file1.txt", 1024);

    t1.join();
    t2.join();

    return 0;
}

使用原子操作：

原子操作是一种不可中断的操作，可以确保在同一时刻只有一个线程访问共享资源。C++11标准库提供了std::atomic模板类来实现原子操作。

#include <iostream>
#include <fstream>
#include <thread>
#include <atomic>

std::atomic<long long> filePointer(0); // 全局原子文件指针

void readFile(const std::string& filename) {
    long long offset = filePointer.fetch_add(1024, std::memory_order_relaxed); // 原子增加文件指针位置

    std::ifstream file(filename, std::ios::binary);
    if (!file) {
        std::cerr << "Error opening file: " << filename << std::endl;
        return;
    }

    file.seekg(offset, std::ios::beg); // 设置文件指针位置
    // ... 在这里进行文件读取操作 ...
}

int main() {
    std::thread t1(readFile, "file1.txt");
    std::thread t2(readFile, "file1.txt");

    t1.join();
    t2.join();

    return 0;
}

请注意，这两种方法都有一定的局限性。互斥锁可能会导致性能下降，因为线程需要等待锁释放。原子操作虽然性能较好，但在某些情况下可能不够灵活。你可以根据具体需求选择合适的方法。

0 赞

0 踩