Subversion Repositories public iLand

Rev

Rev 1221 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
671 werner 1 
/********************************************************************************************
2 
**    iLand - an individual based forest landscape and disturbance model
3 
**    http://iland.boku.ac.at
4 
**    Copyright (C) 2009-  Werner Rammer, Rupert Seidl
5 
**
6 
**    This program is free software: you can redistribute it and/or modify
7 
**    it under the terms of the GNU General Public License as published by
8 
**    the Free Software Foundation, either version 3 of the License, or
9 
**    (at your option) any later version.
10 
**
11 
**    This program is distributed in the hope that it will be useful,
12 
**    but WITHOUT ANY WARRANTY; without even the implied warranty of
13 
**    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14 
**    GNU General Public License for more details.
15 
**
16 
**    You should have received a copy of the GNU General Public License
17 
**    along with this program.  If not, see <http://www.gnu.org/licenses/>.
18 
********************************************************************************************/
19 
 
248 werner 20 
/** @class ThreadRunner
21 
  Encapsulates the invokation of multiple threads for paralellized tasks.
200 werner 22 
  To avoid lost updates during the light influence pattern application, all the resourceUnits
123 Werner 23 
  are divided in two lists based on the index (even vs. uneven). These (for almost all cases)
200 werner 24 
  ensures, that no directly neighboring resourceUnits are processed.
123 Werner 25 
  */
26 
 
27 
#include "global.h"
28 
#include "threadrunner.h"
29 
#include <QtCore>
780 werner 30 
#include <QtConcurrent/QtConcurrent>
475 werner 31 
bool ThreadRunner::mMultithreaded = true; // static
123 Werner 32 
 
33 
ThreadRunner::ThreadRunner()
34 
{
35 
    mMultithreaded = true;
36 
}
37 
 
38 
void ThreadRunner::print()
39 
{
40 
    qDebug() << "Multithreading enabled: "<< mMultithreaded << "thread count:" << QThread::idealThreadCount();
41 
}
42 
 
43 
 
200 werner 44 
void ThreadRunner::setup(const QList<ResourceUnit*> &resourceUnitList)
123 Werner 45 
{
46 
    mMap1.clear(); mMap2.clear();
47 
    bool map=true;
200 werner 48 
    foreach(ResourceUnit *unit, resourceUnitList) {
123 Werner 49 
        if (map)
50 
            mMap1.append(unit);
51 
        else
52 
            mMap2.append(unit);
53 
 
54 
        map = !map;
55 
    }
56 
 
57 
}
58 
 
59 
/// run a given function for each ressource unit either multithreaded or not.
1157 werner 60 
void ThreadRunner::run(void (*funcptr)(ResourceUnit *), const bool forceSingleThreaded )
123 Werner 61 
{
440 werner 62 
    if (mMultithreaded && mMap1.count() > 3 && forceSingleThreaded==false) {
123 Werner 63 
        // execute using QtConcurrent for larger amounts of ressource units...
64 
        QtConcurrent::blockingMap(mMap1,funcptr);
65 
        QtConcurrent::blockingMap(mMap2,funcptr);
66 
    } else {
67 
        // execute serialized in main thread
187 iland 68 
        ResourceUnit *unit;
123 Werner 69 
        foreach(unit, mMap1)
70 
            (*funcptr)(unit);
71 
 
72 
        foreach(unit, mMap2)
73 
            (*funcptr)(unit);
74 
    }
75 
 
76 
}
475 werner 77 
 
78 
/// run a given function for each species
1157 werner 79 
void ThreadRunner::run(void (*funcptr)(Species *), const bool forceSingleThreaded )
475 werner 80 
{
81 
    if (mMultithreaded && mSpeciesMap.count() > 3 && forceSingleThreaded==false) {
82 
        QtConcurrent::blockingMap(mSpeciesMap, funcptr);
83 
    } else {
84 
        // single threaded operation
85 
        Species *species;
86 
        foreach(species, mSpeciesMap)
87 
            (*funcptr)(species);
88 
    }
89 
 
90 
}