replicode
executing.h
Go to the documentation of this file.
1 /*
2 * HUMANOBS - mBrane
3 *
4 * Eric Nivel
5 * Center for Analysis and Design of Intelligent Agents
6 * Reykjavik University, Menntavegur 1, 101 Reykjavik, Iceland
7 * http://cadia.ru.is
8 * Copyright(c)2012
9 *
10 * This software was developed by the above copyright holder as part of
11 * the HUMANOBS EU research project, in collaboration with the
12 * following parties:
13 *
14 * Autonomous Systems Laboratory
15 * Technical University of Madrid, Spain
16 * http://www.aslab.org/
17 *
18 * Communicative Machines
19 * Edinburgh, United Kingdom
20 * http://www.cmlabs.com/
21 *
22 * Istituto Dalle Molle di Studi sull'Intelligenza Artificiale
23 * University of Lugano and SUPSI, Switzerland
24 * http://www.idsia.ch/
25 *
26 * Institute of Cognitive Sciences and Technologies
27 * Consiglio Nazionale delle Ricerche, Italy
28 * http://www.istc.cnr.it/
29 *
30 * Dipartimento di Ingegneria Informatica
31 * University of Palermo, Italy
32 * http://roboticslab.dinfo.unipa.it/index.php/Main/HomePage
33 *
34 *
35 * --- HUMANOBS Open-Source BSD License, with CADIA Clause v 1.0 ---
36 *
37 * Redistribution and use in source and binary forms, with or without
38 * modification, is permitted provided that the following conditions
39 * are met:
40 *
41 * - Redistributions of source code must retain the above copyright
42 * and collaboration notice, this list of conditions and the
43 * following disclaimer.
44 *
45 * - Redistributions in binary form must reproduce the above copyright
46 * notice, this list of conditions and the following
47 * disclaimer in the documentation and/or other materials provided
48 * with the distribution.
49 *
50 * - Neither the name of its copyright holders nor the names of its
51 * contributors may be used to endorse or promote products
52 * derived from this software without specific prior written permission.
53 *
54 * - CADIA Clause: The license granted in and to the software under this
55 * agreement is a limited-use license. The software may not be used in
56 * furtherance of:
57 * (i) intentionally causing bodily injury or severe emotional distress
58 * to any person;
59 * (ii) invading the personal privacy or violating the human rights of
60 * any person; or
61 * (iii) committing or preparing for any act of war.
62 *
63 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
64 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
65 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
66 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
67 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
68 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
69 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
70 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
71 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
72 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
73 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
74 */
75 
76 #ifndef mBrane_executing_h
77 #define mBrane_executing_h
78 
79 #include <CoreLibrary/utils.h>
80 #include <Core/module.h>
81 #include <CoreLibrary/xml_parser.h>
82 #include <mutex>
83 
84 
85 using namespace mBrane::sdk;
86 using namespace mBrane::sdk::module;
87 
88 namespace mBrane
89 {
90 
91 class Node;
92 // Message processing thread class.
93 class XThread
94 {
95 public:
96  static void Xec(XThread *_this);
97  Node *const node;
99  std::mutex mutex;
100 
101  XThread(Node *n);
102  ~XThread();
103  void work(_Payload *p, _Module *c);
104 
106 private:
107 };
108 
109 // XThread pool.
110 class mbrane_dll Executing
111 {
112  friend class XThread;
113 protected:
114 
117  std::mutex supportSync;
118 
119  Executing();
120  ~Executing();
121  bool loadConfig(XMLNode &n);
122  void start();
123  void shutdown();
124 };
125 }
126 
127 
128 #endif
Definition: executing.h:93
std::thread thread
Definition: RR.h:320
std::mutex supportSync
Definition: executing.h:117
uint16_t threadCount
Definition: executing.h:116
Definition: array.h:84
std::thread thread
Definition: executing.h:105
Definition: module.cpp:85
Definition: array.h:86
Definition: payload.h:122
Node *const node
Definition: executing.h:97
Definition: xml_parser.h:172
bool wasSupporting
Definition: executing.h:98
Definition: executing.h:110
void start()
Definition: Perf_modules.h:96
std::mutex mutex
Definition: executing.h:99
Definition: node.h:96
Definition: module_node.h:93
StaticArray< XThread * > xThreads
Definition: executing.h:115
Definition: module.h:99
Definition: array.h:89