您好,登錄后才能下訂單哦!
#include <iostream>
#include <mutex>
#include <vector>
class ConcurrentArray {
private:
std::vector<int> data;
std::mutex mutex;
public:
ConcurrentArray(int size) : data(size) {}
int& operator[](int index) {
std::lock_guard<std::mutex> lock(mutex);
return data[index];
}
void print() {
std::lock_guard<std::mutex> lock(mutex);
for (int i = 0; i < data.size(); i++) {
std::cout << data[i] << " ";
}
std::cout << std::endl;
}
void resize(int newSize) {
std::lock_guard<std::mutex> lock(mutex);
data.resize(newSize);
}
};
int main() {
ConcurrentArray arr(5);
arr[0] = 1;
arr[1] = 2;
arr[2] = 3;
arr.print();
arr.resize(10);
arr[5] = 5;
arr[6] = 6;
arr[7] = 7;
arr.print();
return 0;
}
這個ConcurrentArray
類使用std::mutex
來保護對數組的并發讀寫操作,確保在同一時間只有一個線程可以訪問數組。通過重載operator[]
來提供對數組元素的訪問,并且提供print()
和resize()
方法來打印數組內容和調整數組大小。在main()
函數中展示了如何使用ConcurrentArray
類進行并發讀寫操作。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。