OilfieldToolsNet/opm-simulators
4
0
Fork 0
mirror of https://github.com/OPM/opm-simulators.git synced 2024-11-21 16:57:25 -06:00
Code Issues Packages Projects Releases Wiki Activity

tasklets: introduce the concept of "worker thread index"

Browse Source 
if the current thread is not a worker thread, this returns -1.
This commit is contained in:
Andreas Lauser 2018-04-23 13:16:35 +02:00
parent de167b188b
commit 5c9e20c00e
1 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
tests/models/test_tasklets.cpp
View File

@ -33,6 +33,8 @@
#include <chrono>
#include <iostream>
Ewoms::TaskletRunner *runner;
class SleepTasklet : public Ewoms::TaskletInterface
{
public:
@ -45,8 +47,9 @@ public:
void run()
{
assert(0 <= runner->workerThreadIndex() && runner->workerThreadIndex() < runner->numWorkerThreads());
std::this_thread::sleep_for(std::chrono::milliseconds(mseconds_));
std::cout << "Sleep tasklet " << n_ << " of " << mseconds_ << " ms finished" << std::endl;
std::cout << "Sleep tasklet " << n_ << " of " << mseconds_ << " ms completed by worker thread " << runner->workerThreadIndex() << std::endl;
}
private:
@ -59,23 +62,30 @@ int SleepTasklet::numInstantiated_ = 0;
int main()
{
Ewoms::TaskletRunner tr(2);
int numWorkers = 2;
runner = new Ewoms::TaskletRunner(numWorkers);
// the master thread is not a worker thread
assert(runner->workerThreadIndex() < 0);
assert(runner->numWorkerThreads() == numWorkers);
for (int i = 0; i < 5; ++ i) {
//auto st = std::make_shared<SleepTasklet>((i + 1)*1000);
auto st = std::make_shared<SleepTasklet>(100);
tr.dispatch(st);
runner->dispatch(st);
}
std::cout << "before barrier" << std::endl;
tr.barrier();
runner->barrier();
std::cout << "after barrier" << std::endl;
for (int i = 0; i < 7; ++ i) {
auto st = std::make_shared<SleepTasklet>(500);
tr.dispatch(st);
runner->dispatch(st);
}
delete runner;
return 0;
}