您好,登錄后才能下訂單哦!
#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;
}
這個(gè)ConcurrentArray
類使用std::mutex
來保護(hù)對(duì)數(shù)組的并發(fā)讀寫操作,確保在同一時(shí)間只有一個(gè)線程可以訪問數(shù)組。通過重載operator[]
來提供對(duì)數(shù)組元素的訪問,并且提供print()
和resize()
方法來打印數(shù)組內(nèi)容和調(diào)整數(shù)組大小。在main()
函數(shù)中展示了如何使用ConcurrentArray
類進(jìn)行并發(fā)讀寫操作。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。