C++threadマルチスレッド読み書きロックアプリケーション
1081 ワード
#include
#include
#include
#include
#include
#include
const int N = 100;
using namespace std;
shared_mutex m;
class W_R
{public:
void input();
void output();
private:queueRecv;
};
void W_R::input()
{
for (int i = 0; i < N; i++)
{
unique_lock lock(m);
cout << " " << i< lock(m);
cout << " " << this_thread::get_id() << " " << endl;
cout << Recv.back() << endl;
//Recv.pop();
}
else cout << " , " << endl;
}
cout << "end" << endl;
}
int main()
{
W_R a;
thread in(&W_R::input,&a);
thread out1(&W_R::output,&a);
thread out2(&W_R::output, &a);
in.join();
out1.join();
out2.join();
return 0;
}