在C++中,seekg()
函数用于设置文件读取指针的位置
互斥锁可以确保在同一时刻只有一个线程访问文件。你可以使用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;
}
请注意,这两种方法都有一定的局限性。互斥锁可能会导致性能下降,因为线程需要等待锁释放。原子操作虽然性能较好,但在某些情况下可能不够灵活。你可以根据具体需求选择合适的方法。