Salome HOME
09a520681a69a8a2f5b3f7456a8d6674b2ebaec3
[modules/smesh.git] / src / SMESH / SMESH_ParallelMesh.hxx
1 // Copyright (C) 2007-2022  CEA/DEN, EDF R&D, OPEN CASCADE
2 //
3 // Copyright (C) 2003-2007  OPEN CASCADE, EADS/CCR, LIP6, CEA/DEN,
4 // CEDRAT, EDF R&D, LEG, PRINCIPIA R&D, BUREAU VERITAS
5 //
6 // This library is free software; you can redistribute it and/or
7 // modify it under the terms of the GNU Lesser General Public
8 // License as published by the Free Software Foundation; either
9 // version 2.1 of the License, or (at your option) any later version.
10 //
11 // This library 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 GNU
14 // Lesser General Public License for more details.
15 //
16 // You should have received a copy of the GNU Lesser General Public
17 // License along with this library; if not, write to the Free Software
18 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307 USA
19 //
20 // See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com
21 //
22
23 //  File   : SMESH_ParallelMesh.hxx
24 //  Author : Yoann AUDOUIN, EDF
25 //  Module : SMESH
26 //
27 #ifndef _SMESH_PARALLELMESH_HXX_
28 #define _SMESH_PARALLELMESH_HXX_
29
30 #include "SMESH_Mesh.hxx"
31
32 #include "SMESH_Gen.hxx"
33 #include "SMESH_subMesh.hxx"
34
35 class SMESH_EXPORT SMESH_ParallelMesh: public SMESH_Mesh
36 {
37  public:
38   SMESH_ParallelMesh(int               theLocalId,
39                        SMESH_Gen*        theGen,
40                        bool              theIsEmbeddedMode,
41                        SMESHDS_Document* theDocument);
42
43   virtual ~SMESH_ParallelMesh();
44
45   void Lock() override {_my_lock.lock();};
46   void Unlock() override {_my_lock.unlock();};
47
48   int GetNbThreads() override{return _NbThreads;};
49   void SetNbThreads(long nbThreads) override{_NbThreads=nbThreads;};
50
51   void InitPoolThreads() override {_pool = new boost::asio::thread_pool(_NbThreads);};
52   void DeletePoolThreads() override {delete _pool;};
53
54   void wait() override {_pool->join(); DeletePoolThreads(); InitPoolThreads(); };
55
56   bool IsParallel() override {return _NbThreads > 0;};
57
58   void CreateTmpFolder();
59   void DeleteTmpFolder();
60
61   boost::filesystem::path GetTmpFolder() override {return tmp_folder;};
62   boost::asio::thread_pool* GetPool() override {return _pool;};
63
64   bool ComputeSubMeshes(
65             SMESH_Gen* gen,
66             SMESH_Mesh & aMesh,
67             const TopoDS_Shape & aShape,
68             const ::MeshDimension       aDim,
69             TSetOfInt*                  aShapesId /*=0*/,
70             TopTools_IndexedMapOfShape* allowedSubShapes,
71             SMESH_subMesh::compute_event &computeEvent,
72             const bool includeSelf,
73             const bool complexShapeFirst,
74             const bool   aShapeOnly) override;
75
76  protected:
77   SMESH_ParallelMesh():SMESH_Mesh() {};
78   SMESH_ParallelMesh(const SMESH_ParallelMesh& aMesh):SMESH_Mesh(aMesh) {};
79  private:
80   boost::filesystem::path tmp_folder;
81   boost::asio::thread_pool *     _pool = nullptr; //thread pool for computation
82 };
83 #endif