Miroirs/cppannotations
1
0
Fork 0
mirror of https://gitlab.com/fbb-git/cppannotations synced 2024-11-16 07:48:44 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge branch 'master' of ssh://git.code.sf.net/p/cppannotations/code

Browse source
This commit is contained in:
Frank B. Brokken 2014-09-23 10:15:32 +02:00
commit 9e659ce52c
1 changed files with 10 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
annotations/yo/threading/examples/insertguard.cc
View file

@ -3,16 +3,12 @@
#include <thread>
#include <mutex>
#include <string>
#include <chrono>
using namespace std;
ifstream in;
mutex ioMutex;
bool nLine(int nr)
bool oneLine(istream &in, mutex &mut, int nr)
{
lock_guard<mutex> lg(ioMutex);
lock_guard<mutex> lg(mut);
string line;
if (not getline(in, line))
@ -23,29 +19,22 @@ bool nLine(int nr)
return true;
}
void nio(int nr)
void io(istream &in, mutex &mut, int nr)
{
while (nLine(nr))
this_thread::sleep_for(chrono::nanoseconds(1));
while (oneLine(in, mut, nr))
this_thread::yield();
}
int main(int argc, char **argv)
{
in.open(argv[1]);
ifstream in(argv[1]);
mutex ioMutex;
thread t1(nio, 1);
thread t2(nio, 2);
thread t3(nio, 3);
thread t4(nio, 4);
// thread t1(io, ref(in), ref(ioMutex));
// thread t2(io, ref(in), ref(ioMutex));
// thread t3(io, ref(in), ref(ioMutex));
thread t1(io, ref(in), ref(ioMutex), 1);
thread t2(io, ref(in), ref(ioMutex), 2);
thread t3(io, ref(in), ref(ioMutex), 3);
t1.join();
t2.join();
t3.join();
t4.join();
}