書き込みスレッド同士(あるいは書き込みスレッドと読み込みスレッド間)は排他にしたいですが、読み込みスレッド同士は排他にしたくないとき、どのようにしたらよいでしょうか?
前提:
スレッドwrite_threadはある値をたまに書き込むことがあります。
スレッドread_thread0、スレッドread_thread1は値を読み込むことしかしません。
#include <iostream>
#include <thread>
struct Data{
float x;
float y;
float z;
};
int main(){
Data data {0.0f,0.0f,0.0f};
std::atomic<bool> quit=false;
std::thread write_thread {
[&data,&quit]{
while(!quit){
std::this_thread::sleep_for(std::chrono::milliseconds(20));
data.x +=1;
std::this_thread::sleep_for(std::chrono::milliseconds(20));
data.y +=1;
std::this_thread::sleep_for(std::chrono::milliseconds(20));
data.z +=1;
}
}
};
auto reader = [&data,&quit](unsigned int ms){
while(!quit){
std::this_thread::sleep_for(std::chrono::milliseconds(ms));
std::cout << data.x << "," << data.y << "," << data.z << std::endl;
}
};
std::thread read_thread0 {reader, 30};
std::thread read_thread1 {reader, 40};
std::this_thread::sleep_for(std::chrono::milliseconds(200));
quit = true;
write_thread.join();
read_thread0.join();
read_thread1.join();
}
1,0,0
1,0,0
1,1,0
1,1,1
2,1,1
2,2,1
2,2,1
3,2,2
3,2,2
3,3,2
3,3,3
4,3,3
// ゾロ目で出るようにしたいが、read_thread同士が互いにロックを取り合うようなことはしたくない。
write_thread と read_thread0 はdataに排他的に触る。
write_thread と read_thread1 はdataに排他的に触る。
read_thread0 と read_thread1 は互いにロックを取り合わずにdataに触りたい。